Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.13.0
Description
Flink deployment configuration describe how to configure checkpointing in flink-conf.yamlhttps://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/config/
Checkpointing
You can configure checkpointing directly in code within your Flink job or application. Putting these values here in the configuration defines them as defaults in case the application does not configure anything.
*
*state.backend: The state backend to use. This defines the data structure mechanism for taking snapshots. Common values are filesystem or rocksdb.
state.checkpoints.dir: The directory to write checkpoints to. This takes a path URI like s3://mybucket/flink-app/checkpoints or hdfs://namenode:port/flink/checkpoints.
state.savepoints.dir: The default directory for savepoints. Takes a path URI, similar to state.checkpoints.dir.
In my test for Flink-1.13.0, however,Flink checkpointing was not enabled without 'execution.checkpointing.interval' value in flink-conf.yaml. In order to enable checkpointing in case the application does not configure anything, we need to configure these values in flink-conf.yaml.
- state.backend:
- state.checkpoints.dir:
- state.savepoints.dir:
- execution.checkpointing.interval:
'execution.checkpointing.interval' value missing in document.