[FLINK-5215] Close checkpoint streams upon cancellation

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.1.3
• Fix Version/s: 1.1.4
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Till Rohrmann
• Created: 30/Nov/16 17:17
• Updated: 29/Jan/17 14:42
• Resolved: 01/Dec/16 13:37

Description

Closing checkpoint streams upon cancellation of a Task could help to interrupt the main thread being stuck in the snapshotState method of stateful operator. Otherwise, ff the snapshotState method takes too long to complete, the watch dog will kill the whole TaskManager terminating all other running tasks as well.