flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-12641) Add partition release logic from JM -> TM
Date Tue, 28 May 2019 11:13:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-12641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Chesnay Schepler updated FLINK-12641:
-------------------------------------
    Description: 
Introduce general logic on the JobManager to release partitions that are no longer required.
In the first version, partitions will be kept until the consumer has finished, similarly to
the current behavior.

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

  was:
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.


> 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
>            Priority: Major
>             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 consumer has finished, similarly
to the current behavior.
> Further optimizations, potentially involving failover-regions, can be tackled in a follow-up.



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

Mime
View raw message