Skip to content
代码片段 群组 项目
未验证 提交 517e4d92 编辑于 作者: Yash Mayya's avatar Yash Mayya 提交者: GitHub
浏览文件

MINOR: Update comment on verifyTaskGenerationAndOwnership method in DistributedHerder

Reviewers: Chris Egerton <fearthecellos@gmail.com>
上级 3ddb6231
No related branches found
No related tags found
无相关合并请求
......@@ -1732,9 +1732,7 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
throw ConnectUtils.maybeWrap(cause, "Failed to perform round of zombie fencing");
}
},
() -> {
verifyTaskGenerationAndOwnership(taskId, taskGeneration);
}
() -> verifyTaskGenerationAndOwnership(taskId, taskGeneration)
);
} else {
return worker.startSourceTask(
......@@ -1941,8 +1939,8 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
}
}
// Currently unused, but will be invoked by exactly-once source tasks after they have successfully
// initialized their transactional producer
// Invoked by exactly-once worker source tasks after they have successfully initialized their transactional
// producer to ensure that it is still safe to bring up the task
private void verifyTaskGenerationAndOwnership(ConnectorTaskId id, int initialTaskGen) {
log.debug("Reading to end of config topic to ensure it is still safe to bring up source task {} with exactly-once support", id);
if (!refreshConfigSnapshot(Long.MAX_VALUE)) {
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册