Fix announcer test bad check

This commit is contained in:
fjy 2016-01-01 19:55:22 -08:00
parent fc2257489e
commit 8424b2b456
1 changed files with 1 additions and 5 deletions

View File

@ -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));