[dolphinscheduler] branch dev updated: fix task kill (#9578)

[le...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

leonbao pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new b4017d0afd fix task kill (#9578)
b4017d0afd is described below

commit b4017d0afd29f2ccd497713d8a448125baf93313
Author: caishunfeng <ca...@gmail.com>
AuthorDate: Tue Apr 19 15:26:12 2022 +0800

    fix task kill (#9578)
---
 .../dolphinscheduler/server/worker/processor/TaskCallbackService.java    | 1 -
 1 file changed, 1 deletion(-)

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