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 d43e1e84ec [INLONG-10291][SDK] Fix incorrect initializing of gnet in
Golang SDK (#10294)
add 4555ebfe1c [INLONG-10297][Sort] Fix mysql connector cannot submit to
flink cluster (#10301)
No new revisions were added by this update.
Summary of changes:
.../sort-connectors/mysql-cdc/pom.xml | 1 +
.../apache/inlong/sort/mysql/MySqlTableSource.java | 5 +-
.../mysql/RowDataDebeziumDeserializeSchema.java | 31 +++--
.../inlong/sort}/mysql/source/MySqlSource.java | 140 ++++++++-------------
.../sort}/mysql/source/MySqlSourceBuilder.java | 113 +++++------------
licenses/inlong-sort-connectors/LICENSE | 2 +
6 files changed, 112 insertions(+), 180 deletions(-)
copy
inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort}/mysql/source/MySqlSource.java
(62%)
copy
inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc
=>
sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort}/mysql/source/MySqlSourceBuilder.java
(74%)
