From 8424b2b456a3e5716afd28ffbb915c101a240788 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 1 Jan 2016 19:55:22 -0800 Subject: [PATCH] Fix announcer test bad check --- .../java/io/druid/curator/announcement/AnnouncerTest.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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 f1158f04eff..e095a662621 100644 --- a/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java +++ b/server/src/test/java/io/druid/curator/announcement/AnnouncerTest.java @@ -173,12 +173,8 @@ public class AnnouncerTest extends CuratorTestBase announcer.stop(); - int count = 0; - while ((curator.checkExists().forPath(testPath1) != null) || (curator.checkExists().forPath(testPath1) != null)) { + while ((curator.checkExists().forPath(testPath1) != null) || (curator.checkExists().forPath(testPath2) != null)) { Thread.sleep(100); - if (++count > 10) { - throw new ISE("Curator paths not getting cleaned up"); - } } Assert.assertNull(curator.checkExists().forPath(testPath1));