[tests] Fix ProcessFailureRecovery tests by aligning restart delay parameter with heartbeat pause.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/959d2278 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/959d2278 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/959d2278 Branch: refs/heads/master Commit: 959d227837c3b0c919c467fa59f6d1ec305bc4ad Parents: c8de656 Author: Stephan Ewen <se...@apache.org> Authored: Tue May 12 15:03:34 2015 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Tue May 12 21:35:58 2015 +0200 ---------------------------------------------------------------------- .../flink/test/recovery/AbstractProcessFailureRecoveryTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/959d2278/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java index ddfbeed..d55aff4 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractProcessFailureRecoveryTest.java @@ -115,7 +115,7 @@ public abstract class AbstractProcessFailureRecoveryTest { jmConfig.setString(ConfigConstants.AKKA_WATCH_HEARTBEAT_INTERVAL, "1000 ms"); jmConfig.setString(ConfigConstants.AKKA_WATCH_HEARTBEAT_PAUSE, "6 s"); jmConfig.setInteger(ConfigConstants.AKKA_WATCH_THRESHOLD, 9); - jmConfig.setString(ConfigConstants.DEFAULT_EXECUTION_RETRY_DELAY_KEY, "4 s"); + jmConfig.setString(ConfigConstants.DEFAULT_EXECUTION_RETRY_DELAY_KEY, "10 s"); jmActorSystem = AkkaUtils.createActorSystem(jmConfig, new Some<Tuple2<String, Object>>(localAddress)); ActorRef jmActor = JobManager.startJobManagerActors(jmConfig, jmActorSystem)._1();
