diff --git a/server/src/test/java/io/druid/server/coordination/ServerManagerTest.java b/server/src/test/java/io/druid/server/coordination/ServerManagerTest.java index 3c52714a240..f6a139ffb9c 100644 --- a/server/src/test/java/io/druid/server/coordination/ServerManagerTest.java +++ b/server/src/test/java/io/druid/server/coordination/ServerManagerTest.java @@ -276,7 +276,7 @@ public class ServerManagerTest ) ); - queryNotifyLatch.await(); + queryNotifyLatch.await(1000, TimeUnit.MILLISECONDS); Assert.assertEquals(1, factory.getSegmentReferences().size()); @@ -315,7 +315,7 @@ public class ServerManagerTest ) ); - queryNotifyLatch.await(); + queryNotifyLatch.await(1000, TimeUnit.MILLISECONDS); Assert.assertEquals(1, factory.getSegmentReferences().size()); @@ -358,7 +358,7 @@ public class ServerManagerTest ) ); - queryNotifyLatch.await(25, TimeUnit.MILLISECONDS); + queryNotifyLatch.await(1000, TimeUnit.MILLISECONDS); Assert.assertEquals(1, factory.getSegmentReferences().size()); @@ -392,7 +392,7 @@ public class ServerManagerTest private void waitForTestVerificationAndCleanup(Future future) { try { - queryNotifyLatch.await(25, TimeUnit.MILLISECONDS); + queryNotifyLatch.await(1000, TimeUnit.MILLISECONDS); queryWaitYieldLatch.countDown(); queryWaitLatch.countDown(); future.get(); @@ -720,7 +720,7 @@ public class ServerManagerTest notifyLatch.countDown(); try { - waitYieldLatch.await(); + waitYieldLatch.await(1000, TimeUnit.MILLISECONDS); } catch (Exception e) { throw Throwables.propagate(e); @@ -733,7 +733,7 @@ public class ServerManagerTest public OutType get() { try { - waitLatch.await(); + waitLatch.await(1000, TimeUnit.MILLISECONDS); } catch (Exception e) { throw Throwables.propagate(e);