QuakeWang opened a new pull request, #8099: URL: https://github.com/apache/paimon/pull/8099
### Purpose `CDCSourceSplitReader` generated schema change events per split, but re-added them every time a new data batch was attached to the pooled iterator. This could emit duplicate schema events for a multi-batch split. The same iterator also advanced `recordsToSkip` for both schema events and data events, while restore only skips underlying data rows. A checkpoint taken after schema events could therefore skip real data rows after recovery. ### Tests - `mvn -pl paimon-flink/paimon-flink-cdc -Dtest=CDCSourceSplitReaderTest test` -- 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]
