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 09:53:16 UTC
flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase
Repository: flink
Updated Branches:
refs/heads/master 67e3d9d44 -> f250d95b7
[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/f250d95b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f250d95b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f250d95b
Branch: refs/heads/master
Commit: f250d95b74fa5713f35a61dd5537aa419d1f12c6
Parents: 67e3d9d
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 10:51:30 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/f250d95b/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>>() {