Daniel Harper created BEAM-5372:
-----------------------------------
Summary: [Flink Runner] Make minPauseBetweenCheckpoints setting
available in FlinkPipelineOptions
Key: BEAM-5372
URL: https://issues.apache.org/jira/browse/BEAM-5372
Project: Beam
Issue Type: Improvement
Components: runner-flink
Reporter: Daniel Harper
Assignee: Daniel Harper
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)
