[jira] [Created] (FLINK-12641) Add partition release logic from JM -> TM

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-12641) Add partition release logic from JM -> TM

Shang Yuanchun (Jira)
Chesnay Schepler created FLINK-12641:
----------------------------------------

             Summary: Add partition release logic from JM -> TM
                 Key: FLINK-12641
                 URL: https://issues.apache.org/jira/browse/FLINK-12641
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Coordination, Runtime / Network
            Reporter: Chesnay Schepler
            Assignee: Chesnay Schepler
             Fix For: 1.9.0


Introduce general logic on the JobManager to release partitions that are no longer required.
In the first version, partitions will be kept until the job has finished.

Further optimizations, potentially involving failover-regions, can be tackled in a follow-up.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)