github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-01 22:42:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge a27844a84b into 0824b45c5e

Browse Source
This commit is contained in:
MickYuan 2025-04-10 16:21:16 +08:00 committed by GitHub
commit f82aaaf400
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java
View File

@ -187,8 +187,15 @@ public class TaskGroupContainer extends AbstractContainer {
}
}
// 2.发现该taskGroup下taskExecutor的总状态失败则汇报错误
// 2.发现该taskGroup下taskExecutor的总状态失败则汇报错误，同时关闭失败的taskExecutor
if (failedOrKilled) {
taskFailedExecutorMap.forEach((taskId, taskExecutor) -> {
if (!taskExecutor.isShutdown()) {
taskExecutor.shutdown();
}
});
lastTaskGroupContainerCommunication = reportTaskGroupCommunication(
lastTaskGroupContainerCommunication, taskCountInThisTaskGroup);