From 7e6cc7290d76959032deb1c85111856ca88b1bde Mon Sep 17 00:00:00 2001 From: sihuazhou Date: Thu, 12 Apr 2018 11:10:48 +0800 Subject: [PATCH] Set default FixedRestartDelayStrategy delay to 0s. --- .../java/org/apache/flink/configuration/ConfigConstants.java | 2 +- .../flink/streaming/api/graph/StreamingJobGraphGenerator.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java index f1483603df884..6dd30674921ae 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java @@ -72,7 +72,7 @@ public final class ConfigConstants { */ @PublicEvolving public static final ConfigOption RESTART_STRATEGY_FIXED_DELAY_DELAY = - key("restart-strategy.fixed-delay.delay").defaultValue("1 s"); + key("restart-strategy.fixed-delay.delay").defaultValue("0 s"); /** * Maximum number of restarts in given time interval {@link #RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL} before failing a job diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java index 4e4f84d1d0458..e54101c56ddb5 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java @@ -85,7 +85,7 @@ public class StreamingJobGraphGenerator { * Restart delay used for the FixedDelayRestartStrategy in case checkpointing was enabled but * no restart strategy has been specified. */ - private static final long DEFAULT_RESTART_DELAY = 10000L; + private static final long DEFAULT_RESTART_DELAY = 0L; // ------------------------------------------------------------------------