Flink 1.3.2

Author: wtanaka

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:

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

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

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