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: [email protected]
For additional commands, e-mail: [email protected]
