diff --git a/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java b/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java index 58c01f5e252..dfc6c500970 100644 --- a/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java +++ b/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java @@ -148,7 +148,7 @@ public class AnnouncerTest extends CuratorTestBase ); KillSession.kill(curator.getZookeeperClient().getZooKeeper(), server.getConnectString()); - Assert.assertTrue(timing.awaitLatch(latch)); + Assert.assertTrue(timing.forWaiting().awaitLatch(latch)); Assert.assertArrayEquals(billy, curator.getData().decompressed().forPath(testPath1)); Assert.assertArrayEquals(billy, curator.getData().decompressed().forPath(testPath2));