taskGroupId和LocalTGCommunicationManager里注册id重复的问题
Open
- Dominant language
- Java
- Stars
- 17.4k
- Forks
- 5.7k
- PR merge metrics
- No merged PRs in 30d
Description
taskGroupId看到只能在core.json中定义，而且在com.alibaba.datax.core.container.util.JobAssignUtil#doAssign方法只是简单的从1开始排序。
造成如果同时多个任务运行，LocalTGCommunicationManager里面根据id获取到的Communication可能会错位，导致任务运行失败
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reading core.json, com.alibaba.datax.core.container.util.JobAssignUtil#doAssign, and LocalTGCommunicationManager to trace how taskGroupId values are assigned and used. Reproduce multiple concurrent tasks and verify that each task retrieves its own Communication without ID collisions or misrouting.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- backend, distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100