You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/04/23 04:45:08 UTC
[16/17] flink git commit: [FLINK-9158] [core] Set default
FixedRestartDelayStrategy delay to 0s.
[FLINK-9158] [core] Set default FixedRestartDelayStrategy delay to 0s.
This closes #5839
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb044229
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb044229
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cb044229
Branch: refs/heads/release-1.5
Commit: cb044229e4c480cc22a250130d58dea5d02fbfc8
Parents: d178e3f
Author: sihuazhou <su...@163.com>
Authored: Thu Apr 12 11:10:48 2018 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Apr 22 22:42:44 2018 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/configuration/ConfigConstants.java | 2 +-
.../flink/streaming/api/graph/StreamingJobGraphGenerator.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/cb044229/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
----------------------------------------------------------------------
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 f148360..6dd3067 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<String> 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
http://git-wip-us.apache.org/repos/asf/flink/blob/cb044229/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
----------------------------------------------------------------------
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 4e4f84d..e54101c 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;
// ------------------------------------------------------------------------