Skip to content
Snippets Groups Projects
Commit ea4b932b authored by Sören Henning's avatar Sören Henning
Browse files

Disable checkpointing and set state to RocksDB

parent 8a0db269
Branches apache-flink
No related tags found
No related merge requests found
Pipeline #1685 passed
...@@ -19,10 +19,10 @@ spec: ...@@ -19,10 +19,10 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: "FLINK_STATE_BACKEND"
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: FLINK_PROPERTIES - name: FLINK_PROPERTIES
......
...@@ -23,10 +23,10 @@ spec: ...@@ -23,10 +23,10 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: "FLINK_STATE_BACKEND"
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
......
...@@ -21,9 +21,9 @@ spec: ...@@ -21,9 +21,9 @@ spec:
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
- name: CHECKPOINTING - name: CHECKPOINTING
value: "true" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: FLINK_STATE_BACKEND
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: DEBUG - name: DEBUG
......
...@@ -25,9 +25,9 @@ spec: ...@@ -25,9 +25,9 @@ spec:
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
- name: CHECKPOINTING - name: CHECKPOINTING
value: "true" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: FLINK_STATE_BACKEND
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
......
...@@ -19,10 +19,10 @@ spec: ...@@ -19,10 +19,10 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: FLINK_STATE_BACKEND
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: FLINK_PROPERTIES - name: FLINK_PROPERTIES
......
...@@ -23,10 +23,10 @@ spec: ...@@ -23,10 +23,10 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
#- name: "FLINK_STATE_BACKEND" - name: FLINK_STATE_BACKEND
# value: "rocksdb" value: "rocksdb"
- name: JOB_MANAGER_RPC_ADDRESS - name: JOB_MANAGER_RPC_ADDRESS
value: "flink-jobmanager" value: "flink-jobmanager"
- name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS - name: TASK_MANAGER_NUMBER_OF_TASK_SLOTS
......
...@@ -19,8 +19,8 @@ spec: ...@@ -19,8 +19,8 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
- name: FLINK_STATE_BACKEND - name: FLINK_STATE_BACKEND
value: "rocksdb" value: "rocksdb"
- name: FLINK_STATE_BACKEND_PATH - name: FLINK_STATE_BACKEND_PATH
......
...@@ -23,8 +23,8 @@ spec: ...@@ -23,8 +23,8 @@ spec:
value: "my-confluent-cp-kafka:9092" value: "my-confluent-cp-kafka:9092"
- name: COMMIT_INTERVAL_MS - name: COMMIT_INTERVAL_MS
value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}" value: "{{KAFKA_STREAMS_COMMIT_INTERVAL_MS}}"
#- name: CHECKPOINTING - name: CHECKPOINTING
# value: "false" value: "false"
- name: FLINK_STATE_BACKEND - name: FLINK_STATE_BACKEND
value: "rocksdb" value: "rocksdb"
- name: FLINK_STATE_BACKEND_PATH - name: FLINK_STATE_BACKEND_PATH
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment