[
https://issues.apache.org/jira/browse/FLINK-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-12667.
------------------------------------
Resolution: Fixed
master: b86ba3bf2426d7e5cec5a7d2711fd5b278e863ea
> Add JobID argument to TaskExecutorGateway#releasePartitions
> -----------------------------------------------------------
>
> Key: FLINK-12667
> URL: https://issues.apache.org/jira/browse/FLINK-12667
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.9.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
