[ https://issues.apache.org/jira/browse/BEAM-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Daniel Harper updated BEAM-6234: -------------------------------- Description: The configuration setting {{failOnCheckpointingErrors}} [1] is available in Flink to allow engineers to specify whether the job should fail in the event of checkpoint failure. This should be exposed in {{FlinkPipelineOptions}} and {{FlinkExecutionEnvironments}} to allow users to configure this. The default for this value in Flink is true [2] [1] https://github.com/apache/flink/blob/release-1.5.2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java#L249 [2] https://github.com/apache/flink/blob/release-1.5.2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java#L73 was: The configuration setting {{minPauseBetweenCheckpoints}} [1] is available in Flink to allow a grace period when checkpoints runtime is > checkpoint interval. This should be exposed in {{FlinkPipelineOptions}} and {{FlinkExecutionEnvironments}} to allow users to configure this. The default for this value in Flink is 0ms [2] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.5/api/java/org/apache/flink/streaming/api/environment/CheckpointConfig.html#setMinPauseBetweenCheckpoints-long- [2] https://ci.apache.org/projects/flink/flink-docs-release-1.5/api/java/constant-values.html#org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS > [Flink Runner] Make failOnCheckpointingErrors setting available in > FlinkPipelineOptions > --------------------------------------------------------------------------------------- > > Key: BEAM-6234 > URL: https://issues.apache.org/jira/browse/BEAM-6234 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Daniel Harper > Assignee: Daniel Harper > Priority: Trivial > Fix For: 2.8.0 > > > The configuration setting {{failOnCheckpointingErrors}} [1] is available in > Flink to allow engineers to specify whether the job should fail in the event > of checkpoint failure. > This should be exposed in {{FlinkPipelineOptions}} and > {{FlinkExecutionEnvironments}} to allow users to configure this. > The default for this value in Flink is true [2] > [1] > https://github.com/apache/flink/blob/release-1.5.2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java#L249 > [2] > https://github.com/apache/flink/blob/release-1.5.2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java#L73 -- This message was sent by Atlassian JIRA (v7.6.3#76005)