Stefan Richter created FLINK-10377: -------------------------------------- Summary: Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete Key: FLINK-10377 URL: https://issues.apache.org/jira/browse/FLINK-10377 Project: Flink Issue Type: Bug Components: Streaming Connectors Affects Versions: 1.6.0, 1.5.0 Reporter: Stefan Richter Assignee: Stefan Richter
The precondition {{checkState(pendingTransactionIterator.hasNext(), "checkpoint completed, but no transaction pending");}} in {{TwoPhaseCommitSinkFunction.notifyCheckpointComplete()}} seems to strict, because checkpoints can overtake checkpoints and will fail the precondition. In this case the commit was already performed by the first notification and subsumes the late checkpoint. I think the check can be removed. -- This message was sent by Atlassian JIRA (v7.6.3#76005)