in kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/common/ZooKeeperHiveHelper.java [365:392]
public List<String> getServerUris() throws Exception {
CuratorFramework zkClient = null;
List<String> serverUris;
try {
zkClient = startZookeeperClient(null, false);
List<String> serverNodes =
zkClient.getChildren().forPath(ZOOKEEPER_PATH_SEPARATOR + rootNamespace);
serverUris = new ArrayList<String>(serverNodes.size());
for (String serverNode : serverNodes) {
byte[] serverUriBytes =
zkClient
.getData()
.forPath(
ZOOKEEPER_PATH_SEPARATOR
+ rootNamespace
+ ZOOKEEPER_PATH_SEPARATOR
+ serverNode);
serverUris.add(new String(serverUriBytes, StandardCharsets.UTF_8));
}
zkClient.close();
return serverUris;
} catch (Exception e) {
if (zkClient != null) {
zkClient.close();
}
throw e;
}
}