diff --git a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java b/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java index 9a0e8943d6..c3eb07b2ad 100644 --- a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java +++ b/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java @@ -256,6 +256,5 @@ public class TaskCallbackService { public void sendTaskKillResponseCommand(TaskExecutionContext taskExecutionContext) { TaskKillResponseCommand taskKillResponseCommand = buildKillTaskResponseCommand(taskExecutionContext); send(taskExecutionContext.getTaskInstanceId(), taskKillResponseCommand.convert2Command()); - TaskCallbackService.remove(taskExecutionContext.getTaskInstanceId()); } }