Explorar o código

[Fix-14503][Worker] Fix the problem of subprocess cannot be killed (#14504)

Co-authored-by: xiangzihao <460888207@qq.com>
Rick Cheng hai 1 ano
pai
achega
5a6f1c88a3

+ 1 - 2
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/WorkerTaskKillProcessor.java

@@ -85,6 +85,7 @@ public class WorkerTaskKillProcessor implements WorkerRpcProcessor {
                 return;
             }
 
+            boolean result = doKill(taskExecutionContext);
             this.cancelApplication(taskInstanceId);
 
             int processId = taskExecutionContext.getProcessId();
@@ -97,8 +98,6 @@ public class WorkerTaskKillProcessor implements WorkerRpcProcessor {
                 return;
             }
 
-            boolean result = doKill(taskExecutionContext);
-
             taskExecutionContext.setCurrentExecutionStatus(
                     result ? TaskExecutionStatus.SUCCESS : TaskExecutionStatus.FAILURE);
             sendTaskKillResponseCommand(channel, message.getOpaque(), taskExecutionContext);