[FLINK-12673] Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Andrey Zagrebin
• Reporter: Andrey Zagrebin
• Created: 29/May/19 13:08
• Updated: 06/Jun/19 08:52
• Resolved: 06/Jun/19 08:52

Description

At the moment NetworkEnvironment.getResultPartitionManager is used to query TaskExecutor whether all partitions are released. We should hide this direct access to ResultPartitionManager behind a Shuffle API method call: NetworkEnvironment.getUnreleasedPartitions.

Issue Links

• links to: GitHub Pull Request #8566