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

Reply via email to