[FLINK-5218] Eagerly close checkpoint streams on cancellation

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.1.3
• Fix Version/s: 1.1.4, 1.2.0
• Component/s: Runtime / State Backends
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 01/Dec/16 11:22
• Updated: 02/Dec/16 12:23
• Resolved: 02/Dec/16 12:23

Description

Some output streams perform blocking operations that cannot be properly interrupted. This causes cancellations to take very long when happening concurrently to large synchronous state snapshot operations.

Closing the streams concurrently helps to abort these blocking operations.

This might already be fixed in 1.2 by the CloseableRegistry.

Issue Links

• links to: GitHub Pull Request #2920