[ https://issues.apache.org/jira/browse/FLINK-21328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhu Zhu closed FLINK-21328. --------------------------- Resolution: Fixed done via 0ca36150bc76056ca4ceae28c7eb6ec0a2dd5127 > Optimize the initialization of DefaultExecutionTopology > ------------------------------------------------------- > > Key: FLINK-21328 > URL: https://issues.apache.org/jira/browse/FLINK-21328 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Coordination > Reporter: Zhilong Hong > Assignee: Zhilong Hong > Priority: Major > Labels: pull-request-available > Fix For: 1.13.0 > > > Based on FLINK-21326, the {{consumedResults}} in {{DefaultExecutionVertex}} > and {{consumers}} in {{DefaultResultPartition}} can be replaced with > {{ConsumedPartitionGroup}} and {{ConsumerVertexGroup}} in {{EdgeManager}}. > # The method > {{DefaultExecutionTopology#connectVerticesToConsumedPartitions}} could be > removed. > # All the related usages should be fixed. > The detailed design doc is located at: > https://docs.google.com/document/d/1OjGAyJ9Z6KsxcMtBHr6vbbrwP9xye7CdCtrLvf8dFYw/edit#heading=h.zary7uv1ev22 -- This message was sent by Atlassian Jira (v8.3.4#803005)