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)