[FLINK-12078] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 01/Apr/19 11:24
• Updated: 03/Apr/19 15:45
• Resolved: 03/Apr/19 15:45

Description

Currently TaskEventDispatcher is maintained in NetworkEnvironment for register/unregister partition and used for NettyConnectionManager. In order for further decoupling Task with NetworkEnvironment, we introduce TaskEventPublisher interface for providing publish method only. Then the NetworkEnvironment could maintain TaskEventPublisher and the register/unregister would be removed outside to be handled by Task directly.

To do so, the NetworkEnvironment#unregisterTask would be removed finally and the partition/gate#close could be instead.

 

Issue Links

• links to: GitHub Pull Request #8095