Rui Fan created FLINK-30213:
-------------------------------
Summary: The edge is wrong when the vertex parallelism is changed
Key: FLINK-30213
URL: https://issues.apache.org/jira/browse/FLINK-30213
Project: Flink
Issue Type: Bug
Components: Runtime / Configuration
Affects Versions: 1.17.0
Reporter: Rui Fan
Fix For: 1.17.0
Attachments: image-2022-11-25-17-02-12-492.png,
image-2022-11-25-17-06-53-466.png
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.
!image-2022-11-25-17-02-12-492.png|width=1318,height=356!
!image-2022-11-25-17-06-53-466.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
