[FLINK-6685] SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.1, 1.4.0
• Assignee: Stefan Richter
• Reporter: Stefan Richter
• Created: 23/May/17 13:34
• Updated: 13/Jun/17 09:48
• Resolved: 13/Jun/17 09:47

Description

The SafetyNetCloseableRegistry is closed to early in triggerCheckpointBarrier(...). Right now, it seems like the code assumes that statefulTask.triggerCheckpoint(...) is blocking - which it is not. Like this, the registry can be closed while the checkpoint is still running.

Issue Links

• links to: GitHub Pull Request #4108