Browse Source

fix task kill (#9578)

caishunfeng 3 years ago
parent
commit
b4017d0afd

+ 0 - 1
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());
     }
 }