Chesnay Schepler created FLINK-12612:
----------------------------------------
Summary: Track stored paritions on the TM
Key: FLINK-12612
URL: https://issues.apache.org/jira/browse/FLINK-12612
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination, Runtime / Network
Reporter: Chesnay Schepler
Assignee: Chesnay Schepler
Fix For: 1.9.0
The TaskExecutor has to track which partitions it has stored, grouped by JobID.
This is necessary so that the TaskExecutor only disconnects from the JobManager
if it no longer stores relevant (i.e., belonging to the corresponding job)
partitions (similar to the taskSlotTable).
Additionally this is needed so that the TaskExecutor can independently cleanup
partitions for a given job if the connection to the corresponding JobManager is
lost.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
