[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638589#comment-17638589
]
Rui Fan commented on FLINK-30213:
---------------------------------
Hi [~gyfora] [~mxm] , please help take a look, and I can fix this bug.
BTW, I am very interested in AutoScaling and hope to participate due to it's a
very useful feature for our company.
> 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
> Priority: Major
> 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)
