zhang-arvin commented on PR #11844: URL: https://github.com/apache/seatunnel/pull/11844#issuecomment-5409453298
@DanielLeens Thanks for the thorough review and catching the checkpoint-restore gap in the `SnapshotPhaseState` branch. I've applied a fix in `IncrementalSource.java`: 1. Added `getCheckpointCapturedTables(SnapshotPhaseState)` — derives table set from checkpoint bookkeeping instead of live discovery 2. Fixed `SnapshotPhaseState` branch in `restoreEnumerator()` to use checkpoint-derived tables 3. Refactored `restore()` to use the same helper This fix is scoped to shared `connector-cdc-base` and benefits both MySQL-CDC and Postgres-CDC. Please take another look when you have time. -- 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]
