[FLINK-12667] Add JobID argument to TaskExecutorGateway#releasePartitions

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 29/May/19 07:21
• Updated: 13/Jun/19 13:56
• Resolved: 13/Jun/19 13:56

Description

The TM is informed about partitions that should be releases via TaskExecutorGateway#releasePartitions(Collection<ResultPartitionID>).
This signature makes it a bit tricky to keep track of which partitions still exist for a given job, as the TM would have to maintain a map (partition -> jobID), in addition to a map (jobID -> partitions)

We could include the JobID as a parameter to simplify this. This doens't interfere with current use-cases.

Issue Links

• links to: GitHub Pull Request #8630