Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10653 Introduce Pluggable Shuffle Service Architecture
  3. FLINK-12078

Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

    XMLWordPrintableJSON

    Details

      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.

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                zjwang Zhijiang
                Reporter:
                zjwang Zhijiang
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m