From c56eeb95980893a60e3b382ea560bcf8312671e4 Mon Sep 17 00:00:00 2001 From: Michael Stack Date: Sun, 20 Jan 2013 22:56:15 +0000 Subject: [PATCH] HBASE-7577 Review names of all znodes in zk to make sure they are sensible before 0.96 git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1435995 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java | 2 +- .../org/apache/hadoop/hbase/master/TestAssignmentManager.java | 2 +- .../apache/hadoop/hbase/zookeeper/TestRecoverableZooKeeper.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java index 48fe6955d63..af992791762 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.java @@ -206,7 +206,7 @@ public class ZooKeeperWatcher implements Watcher, Abortable, Closeable { clusterStateZNode = ZKUtil.joinZNode(baseZNode, conf.get("zookeeper.znode.state", "running")); assignmentZNode = ZKUtil.joinZNode(baseZNode, - conf.get("zookeeper.znode.unassigned", "unassigned")); + conf.get("zookeeper.znode.unassigned", "region-in-transition")); tableZNode = ZKUtil.joinZNode(baseZNode, conf.get("zookeeper.znode.tableEnableDisable", "table")); clusterIdZNode = ZKUtil.joinZNode(baseZNode, diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java index 8880fa0f3ac..16804a8318a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentManager.java @@ -689,7 +689,7 @@ public class TestAssignmentManager { }; ((ZooKeeperWatcher) zkw).registerListener(am); Mockito.doThrow(new InterruptedException()).when(recoverableZk) - .getChildren("/hbase/unassigned", null); + .getChildren("/hbase/region-in-transition", null); am.setWatcher((ZooKeeperWatcher) zkw); try { am.processDeadServersAndRegionsInTransition(null); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/TestRecoverableZooKeeper.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/TestRecoverableZooKeeper.java index a7b0c4b34c7..6bf5869bf66 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/TestRecoverableZooKeeper.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/zookeeper/TestRecoverableZooKeeper.java @@ -69,7 +69,7 @@ public class TestRecoverableZooKeeper { @Test public void testSetDataVersionMismatchInLoop() throws Exception { - String znode = "/hbase/unassigned/9af7cfc9b15910a0b3d714bf40a3248f"; + String znode = "/hbase/region-in-transition/9af7cfc9b15910a0b3d714bf40a3248f"; Configuration conf = TEST_UTIL.getConfiguration(); Properties properties = ZKConfig.makeZKProps(conf); ZooKeeperWatcher zkw = new ZooKeeperWatcher(conf, "testSetDataVersionMismatchInLoop",