You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2022/02/08 09:12:09 UTC

[GitHub] [flink] rkhachatryan commented on pull request #18654: [FLINK-25997][state/changelog] Fix materialization boundary for FsSta…

rkhachatryan commented on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032378137


   Thanks for the PR @masteryhx 
   
   I have a couple of high-level remarks:
   - with materialization enabled (100ms interval), `ProcessingTimeWindowCheckpointingITCase#testSlidingProcessingTimeWindow` fails locally; could you please check this?
   - the change essentially replaces the use of `lastAppendedSequenceNumber` with `nextAppendedSequenceNumber` (and the former isn't use in production code anymore); so the latter should be covered by tests (e.g. `FsStateChangelogWriterSqnTest`)
   
   @flinkbot run azure


-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org