davidzollo commented on PR #11503: URL: https://github.com/apache/seatunnel/pull/11503#issuecomment-5549137967
## Descoped this branch back to just the CDC restore fix Per Daniel's outstanding Issue 1, I pushed `1e0d7ab0e9` which removes the two files that had drifted in through repeated `dev`-sync merges and never belonged in this PR: - **`TaskExecutionService.java`** (the `BlockingWorker` start-latch fix): this was a stale, earlier snapshot of the fix already tracked and more thoroughly reviewed under #11727 (which has since evolved to a per-generation `ownedContext` instead of a shared `executionContexts` lookup). No new PR needed — it lands via #11727. - **`RocketMqConsumerThread.java` / `RocketMqSourceReader.java`** (the consumer-shutdown-ordering fix): unrelated to CDC schema restore, and also present unrelated in #11458. Split it out into its own PR: #12099, with a dedicated unit test. Both files were checked out verbatim from the current `dev` HEAD, so this reverts exactly those two out-of-scope diffs and nothing else. The CDC restore diff itself (`IncrementalSourceReader`, `RestoreTableSchemaEvent`, the schema-dispatch pipeline, tests, docs) is untouched — still the same content Daniel already reviewed as source-level sound. @DanielLeens — over to you for a fresh CI/diff check on the cleaned head. -- 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]
