zhijiang created FLINK-11726: -------------------------------- Summary: Refactor the creation of ResultPartition and InputGate into NetworkEnvironment Key: FLINK-11726 URL: https://issues.apache.org/jira/browse/FLINK-11726 Project: Flink Issue Type: Sub-task Components: Network Reporter: zhijiang Assignee: zhijiang Fix For: 1.9.0
The {{ResultPartition}} and {{InputGate}} are created in {{Task}} currently. Based on pluggable {{ShuffleManager}}, they should be created via {{ShuffleService}}. The {{NetworkEnvironment}} would be refactored into {{NetworkShuffleService}} future. So we migrate the process of creating {{ResultPartition}} and {{InputGate}} into current {{NetworkEnvironment}}. The {{BufferPool}} and metrics setup can also be done after the creation. Then we can remove the process of {{NetworkEnvironment#registerTask}}. -- This message was sent by Atlassian JIRA (v7.6.3#76005)