Skip to content
Permalink
Browse files
[FLINK-19107] Add checkpointing and recovery options to template flin…
…k-conf.yaml

This also removes some no longer required configuration, like max
concurrent checkpoints = 1 and legacy scheduler.

This closes #6.
  • Loading branch information
tzulitai committed Sep 25, 2020
1 parent e7c8f65 commit 772d55809ab9f9e0f6aae52b234c34db743ceb2f
Showing 1 changed file with 18 additions and 3 deletions.
@@ -14,20 +14,35 @@
# limitations under the License.
# This file is the base for the Apache Flink configuration

statefun.flink-job-name: Statefun Application

#==============================================================================
# Configurations strictly required by Stateful Functions. Do not change.
#==============================================================================

classloader.parent-first-patterns.additional: org.apache.flink.statefun;org.apache.kafka;com.google.protobuf
execution.checkpointing.max-concurrent-checkpoints: 1
jobmanager.scheduler: legacy

#==============================================================================
# Recommended configurations. Users may change according to their needs.
# Fault tolerance, checkpointing and recovery.
# For more related configuration options, please see: https://ci.apache.org/projects/flink/flink-docs-master/ops/config.html#fault-tolerance
#==============================================================================

# Uncomment the below to enable checkpointing for your application
#execution.checkpointing.mode: EXACTLY_ONCE
#execution.checkpointing.interval: 5sec

restart-strategy: fixed-delay
restart-strategy.fixed-delay.attempts: 2147483647
restart-strategy.fixed-delay.delay: 1sec

state.backend: rocksdb
state.backend.rocksdb.timer-service.factory: ROCKSDB
state.checkpoints.dir: file:///checkpoint-dir
state.backend.incremental: true

#==============================================================================
# Recommended memory configurations. Users may change according to their needs.
#==============================================================================

jobmanager.memory.process.size: 1g
taskmanager.memory.process.size: 4g

0 comments on commit 772d558

Please sign in to comment.