You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 08:10:00 UTC

[jira] [Created] (FLINK-12612) Track stored paritions on the TM

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)