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/22 20:40:50 UTC
[14/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/cc7c3c4f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cc7c3c4f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cc7c3c4f
Branch: refs/heads/master
Commit: cc7c3c4fd46df0b0cb427e6d67ead8e3d64fe8f7
Parents: c491400
Author: sihuazhou <su...@163.com>
Authored: Thu Apr 12 11:10:48 2018 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Apr 22 16:28:35 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/cc7c3c4f/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/cc7c3c4f/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;
// ------------------------------------------------------------------------