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 <[email protected]>
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() {
