paulo-t opened a new pull request, #4431: URL: https://github.com/apache/flink-cdc/pull/4431
This PR fixes Oracle pipeline table identifiers so data change events, schema change events, and CreateTableEvent consistently use the full `database.schema.table` identifier. Without this, some paths drop the database/catalog part and emit only `schema.table`, which can break downstream routing and schema evolution when jobs rely on three-part table IDs. ### Changes - Read data change table IDs from the Debezium SourceRecord source struct instead of parsing the Kafka topic. - Preserve the Debezium catalog/database part when converting schema change table IDs. - Emit CreateTableEvent with the same full table identifier. - Add unit coverage for data events, DDL parsing, and CreateTableEvent ID conversion. ### Tests - Attempted: `mvn -pl flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle -DskipITs -Dspotless.check.skip=true -Dcheckstyle.skip=true -Dtest=OracleEventDeserializerTest,OracleAntlrDdlParserTest,OraclePipelineRecordEmitterTest test` - Result: local Maven did not reach the test phase and got stuck 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]
