hutiefang76 opened a new pull request, #704: URL: https://github.com/apache/doris-flink-connector/pull/704
# Proposed changes Issue Number: close #598 ## Problem Summary: When CDC database synchronization omits the target database, a dynamically created table is routed to `null.<table>` although initial tables use their source database. Resolve the CREATE target from `source.db` when the configured target is absent or blank. Preserve explicit target databases and table-name conversion, and reject events where neither database is available. Validation: Maven `-Pflink1` base-module `TestJsonDebeziumSchemaChangeImplV2` runs 27 tests. Three regressions fail against the original implementation; all 27 pass with this patch. Tests cover CREATE schema extraction, events with historyRecord, explicit target/prefix/suffix, and missing database. Maven validation checks were retained. No running Doris/Flink cluster integration test was performed. ## Checklist(Required) 1. Does it affect the original behavior: Yes, missing target databases use the source database. 2. Has unit tests been added: Yes. 3. Has document been added or modified: No Need, existing optional-target behavior is restored. 4. Does it need to update dependencies: No. 5. Are there any changes that cannot be rolled back: No. ## Further comments AI assistance was used for implementation and source review. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
