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 2017/02/16 16:08:02 UTC
[4/6] flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase
[hotfix] [tests] Stabilize FastFailuresITCase
The test triggers 200 immediate failures and recoveries. The restart strategy allowed 200 restarts.
It may happen that another failure occurs as during the execution, in which case the restart attempts are not
sufficient.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3429ea0a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3429ea0a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3429ea0a
Branch: refs/heads/release-1.2
Commit: 3429ea0aa7478fa3161742592a26c87660ff4617
Parents: 2c93a4c
Author: Stephan Ewen <se...@apache.org>
Authored: Wed Feb 15 18:49:29 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Feb 16 14:51:20 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/test/recovery/FastFailuresITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3429ea0a/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
index 8a43ee4..d80c826 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/FastFailuresITCase.java
@@ -58,7 +58,7 @@ public class FastFailuresITCase extends TestLogger {
env.getConfig().disableSysoutLogging();
env.setParallelism(4);
env.enableCheckpointing(1000);
- env.getConfig().setRestartStrategy(RestartStrategies.fixedDelayRestart(200, 0));
+ env.getConfig().setRestartStrategy(RestartStrategies.fixedDelayRestart(210, 0));
DataStream<Tuple2<Integer, Integer>> input = env.addSource(new RichSourceFunction<Tuple2<Integer, Integer>>() {