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/02 09:48:15 UTC

[incubator-inlong] branch master updated (7d5fbf0 -> f0079e5)

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 7d5fbf0  [INLONG-2808][manager]Manager client support kafka sink and fix some problems (#2828)
     add f0079e5  [INLONG-2820][sort] Improve the deserialization processing of the update event in DebeziumDeserializationSchema (#2824)

No new revisions were added by this update.

Summary of changes:
 .../DebeziumDeserializationInfo.java               | 28 ++++++++++++++++++----
 ...t.java => DebeziumDeserializationInfoTest.java} | 10 ++++----
 .../json/debezium/DebeziumJsonDecodingFormat.java  | 13 ++++++++--
 .../DebeziumJsonDeserializationSchema.java         | 28 ++++++++--------------
 .../DebeziumDeserializationSchemaBuilder.java      |  3 ++-
 .../deserialization/FieldMappingTransformer.java   |  8 ++++---
 .../DebeziumDeserializationTest.java               |  1 -
 .../FieldMappingTransformerTest.java               |  7 ++++--
 8 files changed, 62 insertions(+), 36 deletions(-)
 copy inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/deserialization/{JsonDeserializationInfoTest.java => DebeziumDeserializationInfoTest.java} (72%)