Stephan Ewen created FLINK-5218: ----------------------------------- Summary: Eagerly close checkpoint streams on cancellation Key: FLINK-5218 URL: https://issues.apache.org/jira/browse/FLINK-5218 Project: Flink Issue Type: Bug Components: State Backends, Checkpointing Affects Versions: 1.1.3 Reporter: Stephan Ewen Assignee: Stephan Ewen Priority: Critical Fix For: 1.2.0, 1.1.4
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}}. -- This message was sent by Atlassian JIRA (v6.3.4#6332)