[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30213.
------------------------------
Resolution: Fixed
Merged to main:
ded2df542fd5d585842e77d021fb84a92a5bea76..1c2f4eb4ba1d1b5ad403d7991170ca16cb71df56
I am sorry I accidentally rebased the PR instead of squashing the commits. This
was a mistake from my side.
> 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
> Assignee: Maximilian Michels
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.17.0
>
> Attachments: image-2022-11-25-17-02-12-492.png,
> image-2022-11-25-17-06-53-466.png, image-2022-11-25-21-58-48-968.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)
