提交 e283de68 编写于 作者: F fjy

fix another bug with RTR to remove things correctly from running tasks

上级 baedacf9
......@@ -661,7 +661,7 @@ public class RemoteTaskRunner implements TaskRunner, TaskLogProvider
);
tasksToFail.addAll(zkWorker.getRunningTaskIds());
for (String assignedTask : tasksToFail) {
RemoteTaskRunnerWorkItem taskRunnerWorkItem = runningTasks.get(assignedTask);
RemoteTaskRunnerWorkItem taskRunnerWorkItem = runningTasks.remove(assignedTask);
if (taskRunnerWorkItem != null) {
String taskPath = JOINER.join(config.getIndexerTaskPath(), worker.getHost(), assignedTask);
if (cf.checkExists().forPath(taskPath) != null) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册