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/06/26 10:35:00 UTC
[jira] [Created] (FLINK-12997) Release partitions for reset
vertices
Chesnay Schepler created FLINK-12997:
----------------------------------------
Summary: Release partitions for reset vertices
Key: FLINK-12997
URL: https://issues.apache.org/jira/browse/FLINK-12997
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Chesnay Schepler
Assignee: Chesnay Schepler
Fix For: 1.9.0
If a vertex with is reset (e.g., due to a global failover) we also have to issue release calls to the TM to release said partition.
This case is not handled by the partition release strategy as that one deals with releases that could be due to job _progress_ (i.e., a partition no longer being required because we have downstream partitions that we could back on instead in case of failures).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)