本文整理了Java中org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination.handleUnassignedTask()
方法的一些代码示例,展示了ZKSplitLogManagerCoordination.handleUnassignedTask()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKSplitLogManagerCoordination.handleUnassignedTask()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.coordination.ZKSplitLogManagerCoordination
类名称:ZKSplitLogManagerCoordination
方法名:handleUnassignedTask
[英]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.
[中]任务有可能无限期地处于未分配状态——比如SplitLogManager想要重新提交任务。它会强制任务处于未分配状态,但在创建重新扫描任务节点以通知SplitLogWorkers拾取任务之前,任务已死亡。为了防止出现这种情况,SplitLogManager会在启动时重新提交所有孤立和未分配的任务。
代码示例来源:origin: apache/hbase
if (slt.isUnassigned()) {
LOG.debug("Task not yet acquired " + path + ", ver=" + version);
handleUnassignedTask(path);
} else if (slt.isOwned()) {
heartbeat(path, version, slt.getServerName());
代码示例来源:origin: harbby/presto-connectors
if (slt.isUnassigned()) {
LOG.debug("task not yet acquired " + path + " ver = " + version);
handleUnassignedTask(path);
} else if (slt.isOwned()) {
heartbeat(path, version, slt.getServerName());
内容来源于网络,如有侵权,请联系作者删除!