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

Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/04 02:05:49 UTC

[incubator-inlong] branch master updated (859480a -> fc08c70)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from 859480a  [INLONG-2867][Manager] Support report the task result and get tasks for the agent (#2868)
     add fc08c70  [INLONG-2847][Sort] Support whole-database migration from debezium format to canal format (#2848)

No new revisions were added by this update.

Summary of changes:
 .../thirdparty/sort/util/SerializationUtils.java   |   8 +-
 .../inlong/sort/protocol/BuiltInFieldInfo.java     |   1 +
 .../DebeziumDeserializationInfo.java               |  20 ++--
 .../serialization/CanalSerializationInfo.java      |  68 +----------
 .../DebeziumDeserializationInfoTest.java           |  14 ++-
 .../serialization/CanalSerializationInfoTest.java  |  10 +-
 .../inlong/sort/formats/json/MysqlBinLogData.java  |  14 ++-
 .../json/canal/CanalJsonSerializationSchema.java   | 102 ++++++++--------
 .../json/debezium/DebeziumJsonDecodingFormat.java  |  10 +-
 .../DebeziumJsonDeserializationSchema.java         |  58 +++++++--
 .../DebeziumDeserializationSchemaBuilder.java      |  12 +-
 .../DeserializationSchemaFactory.java              |  10 +-
 .../deserialization/FieldMappingTransformer.java   |   5 +
 .../CanalSerializationSchemaBuilder.java           |  36 ++----
 .../serialization/SerializationSchemaFactory.java  |   2 +-
 .../sort/singletenant/flink/utils/CommonUtils.java |  17 ++-
 .../singletenant/flink/DebeziumToCanalITCase.java  |   3 +-
 ...analITCase.java => WholeDBMigrationITCase.java} | 133 +++++++++++++++++----
 .../flink/kafka/RowToCanalKafkaSinkTest.java       |   4 +-
 .../serialization/CanalSerializationTest.java      |   3 +-
 .../singletenant/flink/utils/CommonUtilsTest.java  |  41 +++++++
 21 files changed, 339 insertions(+), 232 deletions(-)
 copy inlong-sort/sort-single-tenant/src/test/java/org/apache/inlong/sort/singletenant/flink/{DebeziumToCanalITCase.java => WholeDBMigrationITCase.java} (60%)