Myasuka commented on issue #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed URL: https://github.com/apache/flink/pull/9386#issuecomment-543192776 @zentol If current `lastCompletedCheckpointId` is `chk-3`, when task starts checkpointing, it would put `snapshotIndicesOfSubTask` with newer checkpoint `chk-4`. Then, the job fails before the checkpoint is completed, and the `chk-4` would not update in `TestingCompletedCheckpointStore` as `lastCompletedCheckpointId`. When the job recovers, it would verify with previous last checkpoint id `chk-3` from `snapshotIndicesOfSubTask` instead of `chk-4` [(ref here)](https://github.com/apache/flink/pull/9386/files#diff-bfb5100206bccf135ef75dc3df04ff88L310) , which means we could still verify the state correctness as well.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services