zhijiang created FLINK-12146:
--------------------------------
Summary: Remove unregister task from NetworkEnvironment to
simplify the interface of ShuffleService
Key: FLINK-12146
URL: https://issues.apache.org/jira/browse/FLINK-12146
Project: Flink
Issue Type: Sub-task
Components: Runtime / Network
Reporter: zhijiang
Assignee: zhijiang
The current {{NetworkEnvironment}} would be the default {{ShuffleService}}
implementation in task manager. In order to make the interface simple, we try
to avoid more interactive with {{NetworkEnvironment}}.
{{NetworkEnvironment#unregisterTask}} is used for closing partition/gate and
releasing partition from {{ResultPartitionManager}}. partition/gate close could
be done in task which already maintains the arrays of them. Further we could
release partition from {{ResultPartitionManager}} inside {{ResultPartition}}
via introducing {{ResultPartition#close(Throwable)}}. To do so, the
{{NetworkEnvironment#unregisterTask}} could be totally replaced to remove.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
