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

[zi...@apache.org]

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

zihaoxiang 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 e77dd2a1ed [Fix-17317][Task-API] Add kill yarn or k8s application after killing task (#17325)
e77dd2a1ed is described below

commit e77dd2a1edb466d299f848db9cbc158c5608562b
Author: njnu-seafish <su...@sina.com>
AuthorDate: Tue Jul 8 10:50:36 2025 +0800

    [Fix-17317][Task-API] Add kill yarn or k8s application after killing task (#17325)
---
 .../dolphinscheduler/plugin/task/api/AbstractCommandExecutor.java      | 3 +++
 1 file changed, 3 insertions(+)

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
index 67a5c4ccac..fa6df28cc3 100644
--- 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 abstract class AbstractCommandExecutor {
             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() {