org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination.setDone()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(114)

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

ZKSplitLogManagerCoordination.setDone介绍

暂无

代码示例

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

private void createNodeFailure(String path) {
 // TODO the Manager should split the log locally instead of giving up
 LOG.warn("Failed to create task node " + path);
 setDone(path, FAILURE);
}

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

private void getDataSetWatchFailure(String path) {
 LOG.warn("Failed to set data watch " + path);
 setDone(path, FAILURE);
}

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

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

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

if (version == Integer.MIN_VALUE) {
 setDone(path, SUCCESS);
 return;
setDone(path, FAILURE);
return;
if (taskFinisher != null && !ZKSplitLog.isRescanNode(watcher, path)) {
 if (taskFinisher.finish(slt.getServerName(), ZKSplitLog.getFileName(path)) == Status.DONE) {
  setDone(path, SUCCESS);
 } else {
  resubmitOrFail(path, CHECK);
 setDone(path, SUCCESS);
LOG.error(HBaseMarkers.FATAL, "logic error - unexpected zk state for path = "
  + path + " data = " + slt.toString());
setDone(path, FAILURE);

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

private void createNodeFailure(String path) {
 // TODO the Manager should split the log locally instead of giving up
 LOG.warn("failed to create task node" + path);
 setDone(path, FAILURE);
}

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

private void getDataSetWatchFailure(String path) {
 LOG.warn("failed to set data watch " + path);
 setDone(path, FAILURE);
}

代码示例来源: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

if (version == Integer.MIN_VALUE) {
 setDone(path, SUCCESS);
 return;
setDone(path, FAILURE);
return;
if (taskFinisher != null && !ZKSplitLog.isRescanNode(watcher, path)) {
 if (taskFinisher.finish(slt.getServerName(), ZKSplitLog.getFileName(path)) == Status.DONE) {
  setDone(path, SUCCESS);
 } else {
  resubmitOrFail(path, CHECK);
 setDone(path, SUCCESS);
LOG.fatal("logic error - unexpected zk state for path = " + path + " data = "
  + slt.toString());
setDone(path, FAILURE);

相关文章