From ea4b932b5a471a0bd8ee09fa20e6447d1f654cbe Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Sun, 31 Jan 2021 21:54:32 +0100
Subject: [PATCH] Disable checkpointing and set state to RocksDB
---
execution/uc1-application/jobmanager-job.yaml | 8 ++++----
execution/uc1-application/taskmanager-job-deployment.yaml | 8 ++++----
execution/uc2-application/jobmanager-job.yaml | 6 +++---
execution/uc2-application/taskmanager-job-deployment.yaml | 6 +++---
execution/uc3-application/jobmanager-job.yaml | 8 ++++----
execution/uc3-application/taskmanager-job-deployment.yaml | 8 ++++----
execution/uc4-application/jobmanager-job.yaml | 4 ++--
execution/uc4-application/taskmanager-job-deployment.yaml | 4 ++--
8 files changed, 26 insertions(+), 26 deletions(-)
diff --git a/execution/uc1-application/jobmanager-job.yaml b/execution/uc1-application/jobmanager-job.yaml
index 4665f296f..acdfc9fcf 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 d029edd50..97ad8cc92 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 10d92d07f..7da5b47ca 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 26e9cdca9..aed222449 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 8c025e435..6a4897870 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 4d0abe008..4725b30b9 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 4225ece4c..f5a1dd24b 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 8bad5b567..a94a38596 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
--
GitLab