This is an automated email from the ASF dual-hosted git repository.
yunqing pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 31e9f9013 [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode
(#6123)
add a225671e5 [INLONG-6113][Sort] Mysql cdc connector support read table
schema when using debezium function (#6128)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/common/enums/MetaField.java | 7 +-
.../org/apache/inlong/sort/protocol/Metadata.java | 5 +-
.../protocol/node/extract/MySqlExtractNode.java | 8 ++-
.../node/extract/MySqlExtractNodeTest.java | 1 +
.../sort/cdc/debezium/DebeziumSourceFunction.java | 10 +++
.../debezium/internal/DebeziumChangeFetcher.java | 12 +++-
.../internal/FlinkDatabaseSchemaHistory.java | 2 +-
.../cdc/mysql/table/MySqlReadableMetadata.java | 28 +++++---
.../apache/inlong/sort/parser/AllMigrateTest.java | 79 ++++++++++++++++++----
.../inlong/sort/formats/json/canal/CanalJson.java | 13 ++++
10 files changed, 137 insertions(+), 28 deletions(-)
