alibaba / alibaba/DataX

请教下:job任务被终止的时候关闭了TaskGroup线程池,但是没有关闭Task所在的子线程,是出于什么的考虑呢?

Open
#2,062 4 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
17.4k
Forks
5.7k
PR merge metrics
No merged PRs in 30d

Description

关闭 TaskGroup线程池
else if (nowJobContainerCommunication.getState() == State.FAILED) {
dealFailedStat(this.containerCommunicator, nowJobContainerCommunication.getThrowable());
}

public void dealFailedStat(AbstractContainerCommunicator frameworkCollector, Throwable throwable) {
this.taskGroupContainerExecutorService.shutdownNow();
throw DataXException.asDataXException(
FrameworkErrorCode.PLUGIN_RUNTIME_ERROR, throwable);
}

Contributor guide

No contributing guide indexed for this repository

Research direction

Start at the FAILED branch and inspect dealFailedStat in the task failure lifecycle. Trace taskGroupContainerExecutorService and the child Task thread ownership to determine what shutdown behavior is intended. The issue does not define a code change or a testable completion condition, so confirm the rationale before proposing a fix.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
backend
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.