Add the wait so the test will consistently pass
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/23452120 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/23452120 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/23452120 Branch: refs/heads/master Commit: 2345212017802995198cd22548f811eca6d63968 Parents: 17ac0d0 Author: Tim <[email protected]> Authored: Mon Sep 24 21:20:20 2012 -0400 Committer: Tim <[email protected]> Committed: Mon Sep 24 21:20:20 2012 -0400 ---------------------------------------------------------------------- .../clusterstatus/ZookeeperClusterStatusTest.java | 10 ++++++++-- 1 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/23452120/src/blur-core/src/test/java/org/apache/blur/manager/clusterstatus/ZookeeperClusterStatusTest.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/test/java/org/apache/blur/manager/clusterstatus/ZookeeperClusterStatusTest.java b/src/blur-core/src/test/java/org/apache/blur/manager/clusterstatus/ZookeeperClusterStatusTest.java index cd55768..27d1e6e 100644 --- a/src/blur-core/src/test/java/org/apache/blur/manager/clusterstatus/ZookeeperClusterStatusTest.java +++ b/src/blur-core/src/test/java/org/apache/blur/manager/clusterstatus/ZookeeperClusterStatusTest.java @@ -183,9 +183,15 @@ public class ZookeeperClusterStatusTest { public void testIsEnabledEnabledTable() throws KeeperException, InterruptedException { createTable("enabledtable", true); assertTrue(clusterStatus.isEnabled(false, DEFAULT, "enabledtable")); - assertTrue(clusterStatus.isEnabled(true, DEFAULT, "enabledtable")); + + new WaitForAnswerToBeCorrect(20L) { + @Override + public Object run() { + return clusterStatus.isEnabled(true, DEFAULT, "enabledtable"); + } + }.test(true); } - + private void createTable(String name) throws KeeperException, InterruptedException { createTable(name, true); }
