Repository: incubator-blur Updated Branches: refs/heads/blur-374 b1632d10c -> 7e9a9f17e
Switch test to use retrying client to avoid some timing issues Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/f91db754 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/f91db754 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/f91db754 Branch: refs/heads/blur-374 Commit: f91db7548ae04c983196002b4cc18c4f85525896 Parents: e00d1c5 Author: twilliams <[email protected]> Authored: Sun Sep 14 09:22:56 2014 -0400 Committer: twilliams <[email protected]> Committed: Sun Sep 14 09:22:56 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/blur/manager/indexserver/SafeModeTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f91db754/blur-core/src/test/java/org/apache/blur/manager/indexserver/SafeModeTest.java ---------------------------------------------------------------------- diff --git a/blur-core/src/test/java/org/apache/blur/manager/indexserver/SafeModeTest.java b/blur-core/src/test/java/org/apache/blur/manager/indexserver/SafeModeTest.java index eeae856..ed5a301 100644 --- a/blur-core/src/test/java/org/apache/blur/manager/indexserver/SafeModeTest.java +++ b/blur-core/src/test/java/org/apache/blur/manager/indexserver/SafeModeTest.java @@ -30,6 +30,7 @@ import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; import org.apache.blur.MiniCluster; +import org.apache.blur.zookeeper.ZooKeeperClient; import org.apache.blur.zookeeper.ZooKeeperLockManager; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.WatchedEvent; @@ -62,7 +63,7 @@ public class SafeModeTest { @Before public void setup() throws IOException { - zk = new ZooKeeper(miniCluster.getZkConnectionString(), 20000, new Watcher() { + zk = new ZooKeeperClient(miniCluster.getZkConnectionString(), 20000, new Watcher() { @Override public void process(WatchedEvent event) {
