[Fix-17317][Task-API] Add kill yarn or k8s application after killing task (#17325)

njnu-seafish · web-flow · commit e77dd2a1edb4 · 2025-07-08T10:50:36.000+08:00
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractCommandExecutor.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractCommandExecutor.java
@@ -221,6 +221,9 @@ public void cancelApplication() throws InterruptedException {
             log.error("Failed to kill process tree for task: {}, pid: {}",
                     taskRequest.getTaskAppId(), taskRequest.getProcessId());
         }
+
+        // Try to kill yarn or k8s application
+        ProcessUtils.cancelApplication(taskRequest);
     }
 
     private void collectPodLogIfNeeded() {

Original file line number	Diff line number	Diff line change
`@@ -221,6 +221,9 @@ public void cancelApplication() throws InterruptedException {`
`221`	`221`	`log.error("Failed to kill process tree for task: {}, pid: {}",`
`222`	`222`	`taskRequest.getTaskAppId(), taskRequest.getProcessId());`
`223`	`223`	`}`
	`224`	`+`
	`225`	`+ // Try to kill yarn or k8s application`
	`226`	`+ ProcessUtils.cancelApplication(taskRequest);`
`224`	`227`	`}`
`225`	`228`
`226`	`229`	`private void collectPodLogIfNeeded() {`