This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 89699deee5 [INLONG-10425][Manager] Fix the problem of the kafka sink
defines duplicate attributes (#10426)
add 0a106ec6c7 [INLONG-10401][Sort] Add audit time metadata for MySQL
connector and relocate debezium dependencies (#10404)
No new revisions were added by this update.
Summary of changes:
.../protocol/node/extract/MySqlExtractNode.java | 4 +-
.../node/extract/MySqlExtractNodeTest.java | 1 +
.../sort-connectors/mysql-cdc/pom.xml | 4 +
.../apache/inlong/sort/mysql/MySqlTableSource.java | 2 +-
.../mysql/RowDataDebeziumDeserializeSchema.java | 19 ++++-
.../sort/mysql/table/MySqlReadableMetadata.java} | 88 +++++++++-------------
licenses/inlong-sort-connectors/LICENSE | 1 +
7 files changed, 60 insertions(+), 59 deletions(-)
copy
inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/table/MongoDBReadableMetadata.java
=>
sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/table/MySqlReadableMetadata.java}
(54%)
