[FLINK-12641] Release all partitions on job termination

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Coordination, Runtime / Network
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 28/May/19 07:42
• Updated: 29/Jun/19 15:07
• Resolved: 29/Jun/19 15:07

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.