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