You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by yu...@apache.org on 2022/10/11 08:33:28 UTC

[inlong] branch master updated (31e9f9013 -> a225671e5)

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(-)