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

ZKSplitLogManagerCoordination.findOrCreateOrphanTask介绍

暂无

代码示例

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

private void resubmitOrFail(String path, ResubmitDirective directive) {
 if (resubmitTask(path, findOrCreateOrphanTask(path), directive) == false) {
  setDone(path, FAILURE);
 }
}

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

private void heartbeat(String path, int new_version, ServerName workerName) {
 Task task = findOrCreateOrphanTask(path);
 if (new_version != task.last_version) {
  if (task.isUnassigned()) {
   LOG.info("Task " + path + " acquired by " + workerName);
  }
  task.heartbeat(EnvironmentEdgeManager.currentTime(), new_version, workerName);
  SplitLogCounters.tot_mgr_heartbeat.increment();
 } else {
  // duplicate heartbeats - heartbeats w/o zk node version
  // changing - are possible. The timeout thread does
  // getDataSetWatch() just to check whether a node still
  // exists or not
 }
 return;
}

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

/**
 * It is possible for a task to stay in UNASSIGNED state indefinitely - say SplitLogManager wants
 * to resubmit a task. It forces the task to UNASSIGNED state but it dies before it could create
 * the RESCAN task node to signal the SplitLogWorkers to pick up the task. To prevent this
 * scenario the SplitLogManager resubmits all orphan and UNASSIGNED tasks at startup.
 * @param path
 */
private void handleUnassignedTask(String path) {
 if (ZKSplitLog.isRescanNode(watcher, path)) {
  return;
 }
 Task task = findOrCreateOrphanTask(path);
 if (task.isOrphan() && (task.incarnation.get() == 0)) {
  LOG.info("Resubmitting unassigned orphan task " + path);
  // ignore failure to resubmit. The timeout-monitor will handle it later
  // albeit in a more crude fashion
  resubmitTask(path, task, FORCE);
 }
}

代码示例来源：origin: harbby/presto-connectors

private void resubmitOrFail(String path, ResubmitDirective directive) {
 if (resubmitTask(path, findOrCreateOrphanTask(path), directive) == false) {
  setDone(path, FAILURE);
 }
}

代码示例来源：origin: harbby/presto-connectors

private void heartbeat(String path, int new_version, ServerName workerName) {
 Task task = findOrCreateOrphanTask(path);
 if (new_version != task.last_version) {
  if (task.isUnassigned()) {
   LOG.info("task " + path + " acquired by " + workerName);
  }
  task.heartbeat(EnvironmentEdgeManager.currentTime(), new_version, workerName);
  SplitLogCounters.tot_mgr_heartbeat.incrementAndGet();
 } else {
  // duplicate heartbeats - heartbeats w/o zk node version
  // changing - are possible. The timeout thread does
  // getDataSetWatch() just to check whether a node still
  // exists or not
 }
 return;
}

代码示例来源：origin: harbby/presto-connectors

/**
 * It is possible for a task to stay in UNASSIGNED state indefinitely - say SplitLogManager wants
 * to resubmit a task. It forces the task to UNASSIGNED state but it dies before it could create
 * the RESCAN task node to signal the SplitLogWorkers to pick up the task. To prevent this
 * scenario the SplitLogManager resubmits all orphan and UNASSIGNED tasks at startup.
 * @param path
 */
private void handleUnassignedTask(String path) {
 if (ZKSplitLog.isRescanNode(watcher, path)) {
  return;
 }
 Task task = findOrCreateOrphanTask(path);
 if (task.isOrphan() && (task.incarnation.get() == 0)) {
  LOG.info("resubmitting unassigned orphan task " + path);
  // ignore failure to resubmit. The timeout-monitor will handle it later
  // albeit in a more crude fashion
  resubmitTask(path, task, FORCE);
 }
}