This is an automated email from the ASF dual-hosted git repository. diwu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
from 67ca9401 [Improve] Update flink cdc version to 3.1.1 (#438) add 102a13c8 [improve]Improve the entry point for creating tableSchema (#439) No new revisions were added by this update. Summary of changes: .../apache/doris/flink/catalog/DorisCatalog.java | 19 ++- .../flink/catalog/doris/DorisSchemaFactory.java | 128 +++++++++++++++++++ .../flink/sink/schema/SQLParserSchemaManager.java | 33 ++--- .../jsondebezium/JsonDebeziumChangeUtils.java | 42 ------- .../JsonDebeziumSchemaChangeImplV2.java | 32 ++--- .../jsondebezium/SQLParserSchemaChange.java | 6 +- .../apache/doris/flink/tools/cdc/DatabaseSync.java | 39 ++---- .../apache/doris/flink/tools/cdc/SourceSchema.java | 1 + .../catalog/doris/DorisSchemaFactoryTest.java | 140 +++++++++++++++++++++ .../sink/schema/SQLParserSchemaManagerTest.java | 10 +- .../jsondebezium/TestJsonDebeziumChangeUtils.java | 43 ------- .../jsondebezium/TestSQLParserSchemaChange.java | 18 +-- 12 files changed, 324 insertions(+), 187 deletions(-) create mode 100644 flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java create mode 100644 flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactoryTest.java delete mode 100644 flink-doris-connector/src/test/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/TestJsonDebeziumChangeUtils.java --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org