From dbe41f48745bf52458291290bd2aa0fdc8d18560 Mon Sep 17 00:00:00 2001 From: Till Rohrmann Date: Wed, 29 Jun 2016 10:39:08 +0200 Subject: [PATCH] [FLINK-4126] [tests] Increase timeout for ZooKeeperLeaderElectionTest.testZooKeeperReelection The test case failed because it exceeded the deadline. Increasing the deadline and decreasing the number of reelection should harden the test case. --- .../runtime/leaderelection/ZooKeeperLeaderElectionTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.java index 6ebf2dd2c8b..1c0290ad1ab 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.java @@ -137,9 +137,9 @@ public class ZooKeeperLeaderElectionTest extends TestLogger { configuration.setString(ConfigConstants.ZOOKEEPER_QUORUM_KEY, testingServer.getConnectString()); configuration.setString(ConfigConstants.RECOVERY_MODE, "zookeeper"); - Deadline deadline = new FiniteDuration(3, TimeUnit.MINUTES).fromNow(); + Deadline deadline = new FiniteDuration(5, TimeUnit.MINUTES).fromNow(); - int num = 25; + int num = 20; ZooKeeperLeaderElectionService[] leaderElectionService = new ZooKeeperLeaderElectionService[num]; TestingContender[] contenders = new TestingContender[num]; -- GitLab