[ https://issues.apache.org/jira/browse/FLINK-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-10377: ----------------------------------- Labels: pull-request-available (was: ) > 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.5.0, 1.6.0 > Reporter: Stefan Richter > Assignee: Stefan Richter > Priority: Major > Labels: pull-request-available > > 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)