[ https://issues.apache.org/jira/browse/BEAM-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels closed BEAM-6234. ------------------------------------ Resolution: Fixed Fix Version/s: (was: 2.8.0) 2.10.0 > [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.10.0 > > Time Spent: 50m > Remaining Estimate: 0h > > 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)