Stefan Richter created FLINK-6685: ------------------------------------- Summary: SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier Key: FLINK-6685 URL: https://issues.apache.org/jira/browse/FLINK-6685 Project: Flink Issue Type: Bug Affects Versions: 1.3.0 Reporter: Stefan Richter Assignee: Stefan Richter Priority: Blocker
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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)