Daniel Harper created BEAM-6234:
-----------------------------------
Summary: [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
Fix For: 2.8.0
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
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
