From f9467e94517645293957b60b3b016d71a684a545 Mon Sep 17 00:00:00 2001
From: "wtanaka.com" <wtanaka@users.noreply.github.com>
Date: Sat, 16 Sep 2017 14:38:15 -1000
Subject: [PATCH] Flink 1.3.2

---
 master-playbook.yml                              |  3 ++-
 slave1-playbook.yml                              |  3 ++-
 slave2-playbook.yml                              |  3 ++-
 test/integration/master/serverspec/flink_spec.rb | 16 ++++++++++++++++
 4 files changed, 22 insertions(+), 3 deletions(-)

diff --git a/master-playbook.yml b/master-playbook.yml
index 3f10bf0..9fc353f 100644
--- a/master-playbook.yml
+++ b/master-playbook.yml
@@ -21,7 +21,8 @@
       file_basename: kafka
       log_dirs: "/tmp/kafka-logs-kafka"
   - role: wtanaka.apache-flink
-    flink_version: "1.1.2"
+    flink_version: "1.3.2"
+    flink_hadoop_version: "2"
     flink_jobmanager_rpc_address: flink-master
     flink_jobmanager_rpc_port: 6123
     flink_slaves:
diff --git a/slave1-playbook.yml b/slave1-playbook.yml
index 2df845c..2e43241 100644
--- a/slave1-playbook.yml
+++ b/slave1-playbook.yml
@@ -21,7 +21,8 @@
       file_basename: kafka
       log_dirs: "/tmp/kafka-logs-kafka"
   - role: wtanaka.apache-flink
-    flink_version: "1.1.2"
+    flink_version: "1.3.2"
+    flink_hadoop_version: "2"
     flink_jobmanager_rpc_address: flink-master
     flink_jobmanager_rpc_port: 6123
     flink_is_master: False
diff --git a/slave2-playbook.yml b/slave2-playbook.yml
index 9b1dc18..d57dbdd 100644
--- a/slave2-playbook.yml
+++ b/slave2-playbook.yml
@@ -21,7 +21,8 @@
       file_basename: kafka
       log_dirs: "/tmp/kafka-logs-kafka"
   - role: wtanaka.apache-flink
-    flink_version: "1.1.2"
+    flink_version: "1.3.2"
+    flink_hadoop_version: "2"
     flink_jobmanager_rpc_address: flink-master
     flink_jobmanager_rpc_port: 6123
     flink_is_master: False
diff --git a/test/integration/master/serverspec/flink_spec.rb b/test/integration/master/serverspec/flink_spec.rb
index be5db9f..faba25c 100644
--- a/test/integration/master/serverspec/flink_spec.rb
+++ b/test/integration/master/serverspec/flink_spec.rb
@@ -6,4 +6,20 @@
   describe port(8081) do
     it { should be_listening.with('tcp') }
   end
+
+  describe port(6123) do
+    it { should be_listening.with('tcp') }
+  end
+end
+
+describe "Zookeeper" do
+  describe port(2181) do
+    it { should be_listening.with('tcp') }
+  end
+end
+
+describe "Kafka" do
+  describe port(9092) do
+    it { should be_listening.with('tcp') }
+  end
 end