[FLINK-12997] Release partitions for reset vertices

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 26/Jun/19 10:34
• Updated: 01/Jul/19 11:33
• Resolved: 01/Jul/19 11:33

Description

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).

Issue Links

• links to: GitHub Pull Request #8928