platinumhamburg opened a new issue, #2655: URL: https://github.com/apache/fluss/issues/2655
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Fluss version main (development) ### Please describe the bug 🐞 UndoRecoveryITCase.testUndoRecoveryMultipleKeys fails intermittently with: expected: 130L but was: 140L Root cause: FailingCountingReader.keyIndex (used for round-robin key distribution across keys 1,2,3) is not included in checkpoint state. After failover recovery, keyIndex resets to 0 while totalEmitted is correctly restored, shifting the key distribution and causing one key to receive an extra record. ### Solution Include keyIndex in FailingCountingSplit checkpoint/restore and update the split serializer accordingly. ### Are you willing to submit a PR? - [x] I'm willing to submit a PR! -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
