Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.17.0
Description
After FLINK-29501, flink allows overriding JobVertex parallelisms during job submission.
However, the edge should be changed as well. For example, the job has 4 vertex, and all shipStrategyName of all tasks are forward.
After the parallelism of the third task is changed to 1, the second and third edge should be changed from forward to rebalance. But they are still forward.
And from the second picture, the subtask_1 of sink cannot receive any data.
Attachments
Attachments
Issue Links
- causes
-
FLINK-33123 Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler
-
- In Progress
-
- is caused by
-
FLINK-29501 Allow overriding JobVertex parallelisms during job submission
-
- Resolved
-
- links to