diff --git hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java index b3dc5ae..7b591f8 100644 --- hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java +++ hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java @@ -201,6 +201,7 @@ public class ZooKeeperWatcher implements Watcher, Abortable, Closeable { // than service lookup case is not a recommended design pattern. return node.equals(baseZNode) || + node.equals(metaServerZNode) || node.equals(getMasterAddressZNode()) || node.equals(clusterIdZNode)|| node.equals(rsZNode) || diff --git hbase-client/src/test/java/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.java hbase-client/src/test/java/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.java index 8e36b2d..21d2612 100644 --- hbase-client/src/test/java/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.java +++ hbase-client/src/test/java/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.java @@ -37,6 +37,7 @@ public class TestZooKeeperWatcher { "testIsClientReadable", null, false); assertTrue(watcher.isClientReadable(watcher.baseZNode)); + assertTrue(watcher.isClientReadable(watcher.metaServerZNode)); assertTrue(watcher.isClientReadable(watcher.getMasterAddressZNode())); assertTrue(watcher.isClientReadable(watcher.clusterIdZNode)); assertTrue(watcher.isClientReadable(watcher.tableZNode));