paulo-t opened a new pull request, #4434: URL: https://github.com/apache/flink-cdc/pull/4434
This PR adds Oracle CDC streaming support for the XStream adapter. This PR is stacked on top of #4433 because XStream startup and offset handling rely on Oracle timestamp/SCN resolution. After #4433 is merged, this PR should contain only the XStream-specific commit. ### Changes - Add Oracle XStream dependency wiring. - Add local XStream streaming source and LCR event handling for the Debezium version used by Flink CDC. - Advance XStream offsets by fetch low watermark so bounded split logic can progress even when no captured-table event is emitted. - Add OracleSourceReader offset commit gating so processed low watermark is committed only after the stream split is safe, especially with newly added table scanning. - Add unit coverage for XStream streaming behavior, processed offset commit timing, RAC flush strategy, stream fetch task behavior, type conversion, and ROWID chunk handling. ### Tests - Not run locally: Maven currently gets stuck before the test phase while launching Java (`java --enable-native-access=ALL-UNNAMED -version`). -- 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]
