diff --git ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java index 735e745..c859390 100644 --- ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java +++ ql/src/java/org/apache/hadoop/hive/ql/lockmgr/zookeeper/ZooKeeperHiveLockManager.java @@ -93,10 +93,24 @@ public ZooKeeperHiveLockManager() { * Get the quorum server address from the configuration. The format is: * host1:port, host2:port.. **/ - private static String getQuorumServers(HiveConf conf) { - String hosts = conf.getVar(HiveConf.ConfVars.HIVE_ZOOKEEPER_QUORUM); + @VisibleForTesting + static String getQuorumServers(HiveConf conf) { + String[] hosts = conf.getVar(HiveConf.ConfVars.HIVE_ZOOKEEPER_QUORUM).split(","); String port = conf.getVar(HiveConf.ConfVars.HIVE_ZOOKEEPER_CLIENT_PORT); - return hosts + ":" + port; + StringBuilder quorum = new StringBuilder(); + for(int i=0; i