public CuratorFramework startZookeeperClient()

in kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/common/ZooKeeperHiveHelper.java [250:272]

• 21 lines of code
• 4 McCabe index (conditional complexity)

  public CuratorFramework startZookeeperClient(
      ACLProvider zooKeeperAclProvider, boolean addParentNode) throws Exception {
    CuratorFramework zkClient = getNewZookeeperClient(zooKeeperAclProvider);
    zkClient.start();

    // Create the parent znodes recursively; ignore if the parent already exists.
    if (addParentNode) {
      try {
        zkClient
            .create()
            .creatingParentsIfNeeded()
            .withMode(CreateMode.PERSISTENT)
            .forPath(ZooKeeperHiveHelper.ZOOKEEPER_PATH_SEPARATOR + rootNamespace);
        LOG.info("Created the root name space: " + rootNamespace + " on ZooKeeper");
      } catch (KeeperException e) {
        if (e.code() != KeeperException.Code.NODEEXISTS) {
          LOG.error("Unable to create namespace: " + rootNamespace + " on ZooKeeper", e);
          throw e;
        }
      }
    }
    return zkClient;
  }