[GitHub] [flink] wsry commented on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed for unaligned checkpoint

Fri, 08 May 2020 21:18:18 -0700 


wsry commented on pull request #12034:
URL: https://github.com/apache/flink/pull/12034#issuecomment-626102934


   @pnowojski 
   I found that the changed behavior of CheckpointedInputGate fails 
CheckpointBarrierTrackerTest and CreditBasedCheckpointBarrierAlignerTest. I 
have fixed them accordingly. 
   Besides, I found that 
CheckpointBarrierAlignerTestBase#testMultiChannelSkippingCheckpoints is a 
duplication of 
CheckpointBarrierAlignerTestBase#testMultiChannelJumpingOverCheckpoint, so I 
removed CheckpointBarrierAlignerTestBase#testMultiChannelSkippingCheckpoints in 
a hotfix commit.


----------------------------------------------------------------
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:
[email protected]

Reply via email to