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 <[email protected]> Authored: Wed Feb 15 18:49:29 2017 +0100 Committer: Stephan Ewen <[email protected]> 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>>() {
