diff --git a/pom.xml b/pom.xml index b59f7940..c08fe04f 100644 --- a/pom.xml +++ b/pom.xml @@ -103,16 +103,6 @@ log4j 1.2.14 - org.hamcrest hamcrest-core @@ -130,13 +120,13 @@ org.apache.zookeeper zookeeper - 3.4.0-BK-SNAPSHOT + 3.4.0 compile org.apache.bookkeeper bookkeeper-server - 4.0.0-SNAPSHOT + 4.0.0 compile diff --git a/src/main/java/com/yahoo/omid/tso/TSOServer.java b/src/main/java/com/yahoo/omid/tso/TSOServer.java index 2d6b02ed..06398bf7 100644 --- a/src/main/java/com/yahoo/omid/tso/TSOServer.java +++ b/src/main/java/com/yahoo/omid/tso/TSOServer.java @@ -222,7 +222,7 @@ public ChannelPipeline getPipeline() throws Exception { private void recoverState() throws BKException, InterruptedException, KeeperException, IOException { String servers = StringUtils.join(zkservers, ','); ZooKeeper zooKeeper = new ZooKeeper(servers, 1000, null); - BookKeeper bookKeeper = new BookKeeper(zooKeeper); + BookKeeper bookKeeper = new BookKeeper(servers); List children = zooKeeper.getChildren("/ledgers", false); children.remove("available");