本文整理了Java中org.apache.hive.jdbc.ZooKeeperHiveClientException类的一些代码示例，展示了ZooKeeperHiveClientException类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperHiveClientException类的具体详情如下：
包路径：org.apache.hive.jdbc.ZooKeeperHiveClientException
类名称：ZooKeeperHiveClientException

ZooKeeperHiveClientException介绍

暂无

代码示例

代码示例来源：origin: apache/hive

private static List<String> getServerHosts(JdbcConnectionParams connParams, CuratorFramework
  zooKeeperClient) throws Exception {
 List<String> serverHosts = zooKeeperClient.getChildren().forPath("/" + getZooKeeperNamespace(connParams));
 // Remove the znodes we've already tried from this list
 serverHosts.removeAll(connParams.getRejectedHostZnodePaths());
 if (serverHosts.isEmpty()) {
  throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 }
 return serverHosts;
}

代码示例来源：origin: apache/hive

/**
 * Read the next server coordinates (host:port combo) from ZooKeeper. Ignore the znodes already
 * explored. Also update the host, port, jdbcUriString and other configs published by the server.
 *
 * @param connParams
 * @return true if new server info is retrieved successfully
 */
static boolean updateConnParamsFromZooKeeper(JdbcConnectionParams connParams) {
 // Add current host to the rejected list
 connParams.getRejectedHostZnodePaths().add(connParams.getCurrentHostZnodePath());
 String oldServerHost = connParams.getHost();
 int oldServerPort = connParams.getPort();
 // Update connection params (including host, port) from ZooKeeper
 try {
  ZooKeeperHiveClientHelper.configureConnParams(connParams);
  connParams.setJdbcUriString(connParams.getJdbcUriString().replace(
    oldServerHost + ":" + oldServerPort, connParams.getHost() + ":" + connParams.getPort()));
  LOG.info("Selected HiveServer2 instance with uri: " + connParams.getJdbcUriString());
 } catch(ZooKeeperHiveClientException e) {
  LOG.error(e.getMessage());
  return false;
 }
 return true;
}

代码示例来源：origin: apache/hive

private static void updateParamsWithZKServerNode(JdbcConnectionParams connParams,
  CuratorFramework zooKeeperClient, String serverNode) throws Exception {
 String zooKeeperNamespace = getZooKeeperNamespace(connParams);
 connParams.setCurrentHostZnodePath(serverNode);
 // Read data from the znode for this server node
 // This data could be either config string (new releases) or server end
 // point (old releases)
 String dataStr =
   new String(
     zooKeeperClient.getData().forPath("/" + zooKeeperNamespace + "/" + serverNode),
     Charset.forName("UTF-8"));
 // If dataStr is not null and dataStr is not a KV pattern,
 // it must be the server uri added by an older version HS2
 Matcher matcher = kvPattern.matcher(dataStr);
 if ((dataStr != null) && (!matcher.find())) {
  String[] split = dataStr.split(":");
  if (split.length != 2) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper: "
     + dataStr);
  }
  connParams.setHost(split[0]);
  connParams.setPort(Integer.parseInt(split[1]));
 } else {
  applyConfs(dataStr, connParams);
 }
}

代码示例来源：origin: org.spark-project.hive/hive-jdbc

throw new SQLException(
  "Could not open client transport for any of the Server URI's in ZooKeeper: "
    + ze.getMessage(), " 08S01", ze);

代码示例来源：origin: apache/hive

static void configureConnParams(JdbcConnectionParams connParams) throws ZooKeeperHiveClientException {
 if (isZkHADynamicDiscoveryMode(connParams.getSessionVars())) {
  configureConnParamsHA(connParams);
 } else {
  CuratorFramework zooKeeperClient = null;
  try {
   zooKeeperClient = getZkClient(connParams);
   List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
   // Now pick a server node randomly
   String serverNode = serverHosts.get(new Random().nextInt(serverHosts.size()));
   updateParamsWithZKServerNode(connParams, zooKeeperClient, serverNode);
  } catch (Exception e) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
  } finally {
   // Close the client connection with ZooKeeper
   if (zooKeeperClient != null) {
    zooKeeperClient.close();
   }
  }
 }
}

代码示例来源：origin: com.github.hyukjinkwon/hive-jdbc

throw new SQLException(
  "Could not open client transport for any of the Server URI's in ZooKeeper: "
    + ze.getMessage(), " 08S01", ze);

代码示例来源：origin: apache/hive

static List<JdbcConnectionParams> getDirectParamsList(JdbcConnectionParams connParams)
  throws ZooKeeperHiveClientException {
 CuratorFramework zooKeeperClient = null;
 try {
  zooKeeperClient = getZkClient(connParams);
  List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
  final List<JdbcConnectionParams> directParamsList = new ArrayList<>();
  // For each node
  for (String serverNode : serverHosts) {
   JdbcConnectionParams directConnParams = new JdbcConnectionParams(connParams);
   directParamsList.add(directConnParams);
   updateParamsWithZKServerNode(directConnParams, zooKeeperClient, serverNode);
  }
  return directParamsList;
 } catch (Exception e) {
  throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
 } finally {
  // Close the client connection with ZooKeeper
  if (zooKeeperClient != null) {
   zooKeeperClient.close();
  }
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

/**
 * Read the next server coordinates (host:port combo) from ZooKeeper. Ignore the znodes already
 * explored. Also update the host, port, jdbcUriString and other configs published by the server.
 *
 * @param connParams
 * @return true if new server info is retrieved successfully
 */
static boolean updateConnParamsFromZooKeeper(JdbcConnectionParams connParams) {
 // Add current host to the rejected list
 connParams.getRejectedHostZnodePaths().add(connParams.getCurrentHostZnodePath());
 String oldServerHost = connParams.getHost();
 int oldServerPort = connParams.getPort();
 // Update connection params (including host, port) from ZooKeeper
 try {
  ZooKeeperHiveClientHelper.configureConnParams(connParams);
  connParams.setJdbcUriString(connParams.getJdbcUriString().replace(
    oldServerHost + ":" + oldServerPort, connParams.getHost() + ":" + connParams.getPort()));
  LOG.info("Selected HiveServer2 instance with uri: " + connParams.getJdbcUriString());
 } catch(ZooKeeperHiveClientException e) {
  LOG.error(e.getMessage());
  return false;
 }
 return true;
}

代码示例来源：origin: apache/hive

throw new ZooKeeperHiveClientException("Unable to connect to HiveServer2 Active host (No leader found!) after" +
  " " + maxRetries + " retries.");
throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);

代码示例来源：origin: org.apache.hive/hive-jdbc

private static List<String> getServerHosts(JdbcConnectionParams connParams, CuratorFramework
  zooKeeperClient) throws Exception {
 List<String> serverHosts = zooKeeperClient.getChildren().forPath("/" + getZooKeeperNamespace(connParams));
 // Remove the znodes we've already tried from this list
 serverHosts.removeAll(connParams.getRejectedHostZnodePaths());
 if (serverHosts.isEmpty()) {
  throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 }
 return serverHosts;
}

代码示例来源：origin: org.spark-project.hive/hive-jdbc

throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 return serverUri;
} catch (Exception e) {
 throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper", e);
} finally {

代码示例来源：origin: com.github.hyukjinkwon/hive-jdbc

throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 return serverUri;
} catch (Exception e) {
 throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper", e);
} finally {

代码示例来源：origin: org.apache.hive/hive-jdbc

private static void updateParamsWithZKServerNode(JdbcConnectionParams connParams,
  CuratorFramework zooKeeperClient, String serverNode) throws Exception {
 String zooKeeperNamespace = getZooKeeperNamespace(connParams);
 connParams.setCurrentHostZnodePath(serverNode);
 // Read data from the znode for this server node
 // This data could be either config string (new releases) or server end
 // point (old releases)
 String dataStr =
   new String(
     zooKeeperClient.getData().forPath("/" + zooKeeperNamespace + "/" + serverNode),
     Charset.forName("UTF-8"));
 // If dataStr is not null and dataStr is not a KV pattern,
 // it must be the server uri added by an older version HS2
 Matcher matcher = kvPattern.matcher(dataStr);
 if ((dataStr != null) && (!matcher.find())) {
  String[] split = dataStr.split(":");
  if (split.length != 2) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper: "
     + dataStr);
  }
  connParams.setHost(split[0]);
  connParams.setPort(Integer.parseInt(split[1]));
 } else {
  applyConfs(dataStr, connParams);
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

static List<JdbcConnectionParams> getDirectParamsList(JdbcConnectionParams connParams)
  throws ZooKeeperHiveClientException {
 CuratorFramework zooKeeperClient = null;
 try {
  zooKeeperClient = getZkClient(connParams);
  List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
  final List<JdbcConnectionParams> directParamsList = new ArrayList<>();
  // For each node
  for (String serverNode : serverHosts) {
   JdbcConnectionParams directConnParams = new JdbcConnectionParams(connParams);
   directParamsList.add(directConnParams);
   updateParamsWithZKServerNode(directConnParams, zooKeeperClient, serverNode);
  }
  return directParamsList;
 } catch (Exception e) {
  throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
 } finally {
  // Close the client connection with ZooKeeper
  if (zooKeeperClient != null) {
   zooKeeperClient.close();
  }
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

static void configureConnParams(JdbcConnectionParams connParams) throws ZooKeeperHiveClientException {
 if (isZkHADynamicDiscoveryMode(connParams.getSessionVars())) {
  configureConnParamsHA(connParams);
 } else {
  CuratorFramework zooKeeperClient = null;
  try {
   zooKeeperClient = getZkClient(connParams);
   List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
   // Now pick a server node randomly
   String serverNode = serverHosts.get(new Random().nextInt(serverHosts.size()));
   updateParamsWithZKServerNode(connParams, zooKeeperClient, serverNode);
  } catch (Exception e) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
  } finally {
   // Close the client connection with ZooKeeper
   if (zooKeeperClient != null) {
    zooKeeperClient.close();
   }
  }
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

throw new ZooKeeperHiveClientException("Unable to connect to HiveServer2 Active host (No leader found!) after" +
  " " + maxRetries + " retries.");
throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);

代码示例来源：origin: org.spark-project.hive/hive-jdbc

throw new ZooKeeperHiveClientException(e);

代码示例来源：origin: com.github.hyukjinkwon/hive-jdbc

throw new ZooKeeperHiveClientException(e);