Skip to content

[FLINK-39842][oracle-cdc] Support timestamp startup by resolving SCN#4433

Open
paulo-t wants to merge 1 commit into
apache:masterfrom
paulo-t:improvement/oracle-timestamp-startup-scn
Open

[FLINK-39842][oracle-cdc] Support timestamp startup by resolving SCN#4433
paulo-t wants to merge 1 commit into
apache:masterfrom
paulo-t:improvement/oracle-timestamp-startup-scn

Conversation

@paulo-t
Copy link
Copy Markdown

@paulo-t paulo-t commented Jun 4, 2026

This PR makes Oracle CDC timestamp startup usable by resolving the requested startup timestamp to an Oracle SCN and using that SCN as the actual stream offset.

Oracle streaming positions are represented by SCN. The common timestamp startup option therefore needs Oracle-specific conversion before the stream split can start from the requested point in time.

Changes

  • Create Oracle timestamp startup offsets.
  • Resolve timestamp startup offsets to Oracle SCN before loading stream offset state.
  • Add Oracle connection helpers for current SCN and SCN-to-timestamp conversion.
  • Add local Debezium Oracle overrides needed by this connector version.
  • Add unit coverage for offset creation, timestamp-to-SCN resolution, source config propagation, and table factory startup mode handling.

Tests

  • Not run locally: Maven currently gets stuck before the test phase while launching Java (java --enable-native-access=ALL-UNNAMED -version).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant