diff --git a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/common/ZooKeeperHiveHelper.java b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/common/ZooKeeperHiveHelper.java index cf533e2..eb5a4e6 100644 --- a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/common/ZooKeeperHiveHelper.java +++ b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/common/ZooKeeperHiveHelper.java @@ -167,10 +167,10 @@ public CuratorFramework startZookeeperClient(ACLProvider zooKeeperAclProvider, .creatingParentsIfNeeded() .withMode(CreateMode.PERSISTENT) .forPath(ZooKeeperHiveHelper.ZOOKEEPER_PATH_SEPARATOR + rootNamespace); - LOG.info("Created the root name space: " + rootNamespace + " on ZooKeeper for HiveServer2"); + LOG.info("Created the root name space: " + rootNamespace + " on ZooKeeper"); } catch (KeeperException e) { if (e.code() != KeeperException.Code.NODEEXISTS) { - LOG.error("Unable to create HiveServer2 namespace: " + rootNamespace + " on ZooKeeper", e); + LOG.error("Unable to create namespace: " + rootNamespace + " on ZooKeeper", e); throw e; } } diff --git a/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestRemoteHiveMetaStoreZK.java b/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestRemoteHiveMetaStoreZK.java index f858992..3c7375d 100644 --- a/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestRemoteHiveMetaStoreZK.java +++ b/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestRemoteHiveMetaStoreZK.java @@ -28,7 +28,6 @@ @Category(MetastoreCheckinTest.class) public class TestRemoteHiveMetaStoreZK extends TestRemoteHiveMetaStore { private static TestingServer zkServer = null; - private final static String zkRootNamespace = "hs2mszktest"; @Before public void setUp() throws Exception { @@ -38,7 +37,7 @@ public void setUp() throws Exception { // Add ZK specific configurations, so that the metastore can register itself to ZK when // started. MetastoreConf.setVar(conf, ConfVars.THRIFT_URIS, zkServer.getConnectString()); - MetastoreConf.setVar(conf, ConfVars.THRIFT_ZOOKEEPER_NAMESPACE, zkRootNamespace); + MetastoreConf.setVar(conf, ConfVars.THRIFT_ZOOKEEPER_NAMESPACE, this.getClass().getName()); MetastoreConf.setVar(conf, ConfVars.THRIFT_SERVICE_DISCOVERY_MODE, "zookeeper"); } super.setUp();