[ https://issues.apache.org/jira/browse/FLINK-25046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhu Zhu closed FLINK-25046. --------------------------- Resolution: Done master/release-1.15: d0859f6a74e883a9f3123d2e83b154568e202f7a > Convert unspecified edge to rescale when using adapive batch scheduler > ---------------------------------------------------------------------- > > Key: FLINK-25046 > URL: https://issues.apache.org/jira/browse/FLINK-25046 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Coordination > Reporter: Lijie Wang > Assignee: Lijie Wang > Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > Currently, unspecified edges(partitioner == null) will be setted to > {{FORWARD}} when the parallelism of both upstream and downstream is -1. This > may cause many job vertices whose parallelism is not calculated based on data > volume, but is aligned with their upstream vertices' parallelism because of > forward edges, which is contrary to the original intention of our adaptive > batch scheduler. > For this problem, we will convert the unspecfied edges between OperatorChains > to {{RESCALE}} edges(instead of {{FORWARD}} edges) after OperatorChains' > creation. -- This message was sent by Atlassian Jira (v8.20.1#820001)