Merge branch 'apache-flink' into apache-flink-se-cluster-config

execution/uc1-application/jobmanager-job.yaml

@@ -19,6 +19,10 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: "FLINK_STATE_BACKEND"
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: FLINK_PROPERTIES

execution/uc1-application/taskmanager-job-deployment.yaml

@@ -23,6 +23,10 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: "FLINK_STATE_BACKEND"
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS

execution/uc2-application/jobmanager-job.yaml

@@ -20,12 +20,14 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: FLINK_STATE_BACKEND
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: DEBUG
               value: "false"
-            - name: CHECKPOINTING
-              value: "true"
             - name: FLINK_PROPERTIES
               value: |+
                 blob.server.port: 6124

execution/uc2-application/taskmanager-job-deployment.yaml

@@ -24,14 +24,16 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: FLINK_STATE_BACKEND
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
               value: "{{TASKSLOTS}}" # TODO: make configurable
             - name: DEBUG
               value: "false"
-            - name: CHECKPOINTING
-              value: "true"
             - name: FLINK_PROPERTIES
               value: |+
                 blob.server.port: 6124

execution/uc3-application/jobmanager-job.yaml

@@ -19,6 +19,10 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: FLINK_STATE_BACKEND
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: FLINK_PROPERTIES

execution/uc3-application/taskmanager-job-deployment.yaml

@@ -23,6 +23,10 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
+            - name: CHECKPOINTING
+              value: "false"
+            - name: FLINK_STATE_BACKEND
+              value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS
               value: "flink-jobmanager"
             - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS

execution/uc4-application/jobmanager-job.yaml

@@ -19,8 +19,8 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
-            - name: JOB_MANAGER_RPC_ADDRESS
-              value: "flink-jobmanager"
+            - name: CHECKPOINTING
+              value: "false"
             - name: FLINK_STATE_BACKEND
               value: "rocksdb"
             - name: FLINK_STATE_BACKEND_PATH
@@ -34,6 +34,8 @@ spec:
                 jobmanager.memory.process.size: {{MEMORY_LIMIT}}
                 taskmanager.memory.process.size: {{MEMORY_LIMIT}}
                 parallelism.default: {{PARALLELISM}}
+            - name: JOB_MANAGER_RPC_ADDRESS
+              value: "flink-jobmanager"
           resources:
             limits:
               memory: "{{MEMORY_LIMIT}}"

execution/uc4-application/taskmanager-job-deployment.yaml

@@ -23,14 +23,14 @@ spec:
               value: "my-confluent-cp-kafka:9092"
             - name: COMMIT_INTERVAL_MS
               value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
-            - name: JOB_MANAGER_RPC_ADDRESS
-              value: "flink-jobmanager"
-            - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
-              value: "{{TASKSLOTS}}"
+            - name: CHECKPOINTING
+              value: "false"
             - name: FLINK_STATE_BACKEND
               value: "rocksdb"
             - name: FLINK_STATE_BACKEND_PATH
               value: "file:///opt/flink/statebackend"
+            - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
+              value: "{{TASKSLOTS}}"
             - name: FLINK_PROPERTIES
               value: |+
                 blob.server.port: 6124
@@ -40,6 +40,8 @@ spec:
                 jobmanager.memory.process.size: {{MEMORY_LIMIT}}
                 taskmanager.memory.process.size: {{MEMORY_LIMIT}}
                 parallelism.default: {{PARALLELISM}}
+            - name: JOB_MANAGER_RPC_ADDRESS
+              value: "flink-jobmanager"
           resources:
             limits:
               memory: "{{MEMORY_LIMIT}}"