diff --git src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperNodeTracker.java src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperNodeTracker.java index 19dcffe..4a4e4f7 100644 --- src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperNodeTracker.java +++ src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperNodeTracker.java @@ -71,6 +71,11 @@ public abstract class ZooKeeperNodeTracker extends ZooKeeperListener { * or {@link #getData(boolean)} to get the data of the node if it is available. */ public synchronized void start() { + try { + ZKUtil.waitForZKConnectionIfAuthenticating(watcher); + } catch (InterruptedException e) { + LOG.error("Interrupted while waiting for the ZookeeperWatcher to authenticate", e); + } this.watcher.registerListener(this); try { if(ZKUtil.watchAndCheckExists(watcher, node)) {