diff --git a/execution/uc1-application/jobmanager-job.yaml b/execution/uc1-application/jobmanager-job.yaml index 4665f296fa9575d1d69468c4de3d509995f7d7a5..acdfc9fcffb09a3cadc7ea0870c834b61f965e0f 100644 --- a/execution/uc1-application/jobmanager-job.yaml +++ b/execution/uc1-application/jobmanager-job.yaml @@ -19,10 +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: CHECKPOINTING + value: "false" + - name: "FLINK_STATE_BACKEND" + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: FLINK_PROPERTIES diff --git a/execution/uc1-application/taskmanager-job-deployment.yaml b/execution/uc1-application/taskmanager-job-deployment.yaml index d029edd50ce2404af76e90f6cdc8517443d32b1e..97ad8cc9290d056435e7fd0b6b22a39d86b6449c 100644 --- a/execution/uc1-application/taskmanager-job-deployment.yaml +++ b/execution/uc1-application/taskmanager-job-deployment.yaml @@ -23,10 +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: CHECKPOINTING + value: "false" + - name: "FLINK_STATE_BACKEND" + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS diff --git a/execution/uc2-application/jobmanager-job.yaml b/execution/uc2-application/jobmanager-job.yaml index 10d92d07fe48287fe3d66fadcdbf4b1fe99e292e..7da5b47caaf647789ff152e0a6579d0e4ff23992 100644 --- a/execution/uc2-application/jobmanager-job.yaml +++ b/execution/uc2-application/jobmanager-job.yaml @@ -21,9 +21,9 @@ spec: - name: COMMIT_INTERVAL_MS value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" - name: CHECKPOINTING - value: "true" - #- name: "FLINK_STATE_BACKEND" - # value: "rocksdb" + value: "false" + - name: FLINK_STATE_BACKEND + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: DEBUG diff --git a/execution/uc2-application/taskmanager-job-deployment.yaml b/execution/uc2-application/taskmanager-job-deployment.yaml index 26e9cdca9a6b17639c8b9a44cf1d39a0caa610d1..aed2224490a5cc179736bdc8e3b21e4bbe83fe65 100644 --- a/execution/uc2-application/taskmanager-job-deployment.yaml +++ b/execution/uc2-application/taskmanager-job-deployment.yaml @@ -25,9 +25,9 @@ spec: - name: COMMIT_INTERVAL_MS value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" - name: CHECKPOINTING - value: "true" - #- name: "FLINK_STATE_BACKEND" - # value: "rocksdb" + value: "false" + - name: FLINK_STATE_BACKEND + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS diff --git a/execution/uc3-application/jobmanager-job.yaml b/execution/uc3-application/jobmanager-job.yaml index 8c025e4356d8cb68d25b96379bc8568b8f559c6e..6a48978704743ff805706d0e1c23be2dda6000cc 100644 --- a/execution/uc3-application/jobmanager-job.yaml +++ b/execution/uc3-application/jobmanager-job.yaml @@ -19,10 +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: CHECKPOINTING + value: "false" + - name: FLINK_STATE_BACKEND + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: FLINK_PROPERTIES diff --git a/execution/uc3-application/taskmanager-job-deployment.yaml b/execution/uc3-application/taskmanager-job-deployment.yaml index 4d0abe00861447cfcfbd471dbdf0dd5e0747d293..4725b30b9c281cdc616d755f926119b424fbfe56 100644 --- a/execution/uc3-application/taskmanager-job-deployment.yaml +++ b/execution/uc3-application/taskmanager-job-deployment.yaml @@ -23,10 +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: CHECKPOINTING + value: "false" + - name: FLINK_STATE_BACKEND + value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS value: "flink-jobmanager" - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS diff --git a/execution/uc4-application/jobmanager-job.yaml b/execution/uc4-application/jobmanager-job.yaml index 4225ece4c190fc84557a5310c7aab5ff40b9e901..f5a1dd24ba9e38f96247024961c0c13b8ca5387b 100644 --- a/execution/uc4-application/jobmanager-job.yaml +++ b/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: CHECKPOINTING - # value: "false" + - name: CHECKPOINTING + value: "false" - name: FLINK_STATE_BACKEND value: "rocksdb" - name: FLINK_STATE_BACKEND_PATH diff --git a/execution/uc4-application/taskmanager-job-deployment.yaml b/execution/uc4-application/taskmanager-job-deployment.yaml index 8bad5b567ffdca12e0361c64a5f1e0bc17a1e914..a94a38596073c8d29ff80fcfdcf9080bbd50a57f 100644 --- a/execution/uc4-application/taskmanager-job-deployment.yaml +++ b/execution/uc4-application/taskmanager-job-deployment.yaml @@ -23,8 +23,8 @@ spec: value: "my-confluent-cp-kafka:9092" - name: COMMIT_INTERVAL_MS value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" - #- name: CHECKPOINTING - # value: "false" + - name: CHECKPOINTING + value: "false" - name: FLINK_STATE_BACKEND value: "rocksdb" - name: FLINK_STATE_BACKEND_PATH