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