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

ZooKeeperHiveLockManager.checkRedundantNode介绍

暂无

代码示例

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

/** Remove all redundant nodes **/
private void removeAllRedundantNodes() {
 try {
  checkRedundantNode("/" + parent);
 } catch (Exception e) {
  LOG.warn("Exception while removing all redundant nodes", e);
 }
}

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

/** Remove all redundant nodes **/
private void removeAllRedundantNodes() {
 try {
  checkRedundantNode("/" + parent);
 } catch (Exception e) {
  LOG.warn("Exception while removing all redundant nodes", e);
 }
}

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

/** Remove all redundant nodes **/
private void removeAllRedundantNodes() {
 try {
  checkRedundantNode("/" + parent);
 } catch (Exception e) {
  LOG.warn("Exception while removing all redundant nodes", e);
 }
}

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

/** Remove all redundant nodes **/
private void removeAllRedundantNodes() {
 try {
  renewZookeeperInstance(sessionTimeout, quorumServers);
  checkRedundantNode("/" + parent);
 } catch (Exception e) {
  // ignore all errors
 }
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(node) != null) {
   return;
  }
  List<String> children = curatorFramework.getChildren().forPath(node);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = curatorFramework.getChildren().forPath(node);
  if ((children == null) || (children.isEmpty()))
  {
   curatorFramework.delete().forPath(node);
  }
 } catch (Exception e) {
  LOG.warn("Error in checkRedundantNode for node " + node, e);
 }
}

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

private void checkRedundantNode(String node) {
 try {
  // Nothing to do if it is a lock mode
  if (getLockMode(ctx.getConf(), node) != null)
   return;
  List<String> children = zooKeeper.getChildren(node, false);
  for (String child : children) {
   checkRedundantNode(node + "/" + child);
  }
  children = zooKeeper.getChildren(node, false);
  if ((children == null) || (children.isEmpty()))
  {
   zooKeeper.delete(node, -1);
  }
 } catch (Exception e) {
  // ignore all errors
 }
}