Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6283#discussion_r202333518
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -567,22 +560,16 @@ private void configureCheckpointing() {
long interval = cfg.getCheckpointInterval();
if (interval > 0) {
-
ExecutionConfig executionConfig =
streamGraph.getExecutionConfig();
// propagate the expected behaviour for checkpoint
errors to task.
executionConfig.setFailTaskOnCheckpointError(cfg.isFailOnCheckpointingErrors());
-
- // check if a restart strategy has been set, if not
then set the FixedDelayRestartStrategy
- if (executionConfig.getRestartStrategy() == null) {
- // if the user enabled checkpointing, the
default number of exec retries is infinite.
- executionConfig.setRestartStrategy(
-
RestartStrategies.fixedDelayRestart(Integer.MAX_VALUE, DEFAULT_RESTART_DELAY));
- }
} else {
// interval of max value means disable periodic
checkpoint
interval = Long.MAX_VALUE;
}
+
+
--- End diff --
Remove two line breaks
---
