Index: src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java =================================================================== --- src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java (revision 915988) +++ src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java (working copy) @@ -402,6 +402,10 @@ private boolean ensureExists(final String znode) { try { + Stat stat = zooKeeper.exists(znode, false); + if (stat != null) { + return true; + } zooKeeper.create(znode, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); LOG.debug("Created ZNode " + znode);