本文整理了Java中org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination.setDone()
方法的一些代码示例,展示了ZKSplitLogManagerCoordination.setDone()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKSplitLogManagerCoordination.setDone()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!