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

Posted to commits@inlong.apache.org by zi...@apache.org on 2023/05/05 02:54:39 UTC

[inlong] branch master updated (4eea8d3d9 -> 0d80d4de5)

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 4eea8d3d9 [INLONG-7938][Manager] Fix consume list interface does not filter by request (#7939)
     add 0d80d4de5 [INLONG-7945][Sort] Fix MongoDB CDC unable to output the 'replace' records (#7951)

No new revisions were added by this update.

Summary of changes:
 .../MongoDBConnectorDeserializationSchema.java     | 65 ++++++++++++----------
 .../cdc/mongodb/debezium/utils/RecordUtils.java    | 11 ++++
 .../sort/cdc/mongodb/table/MongoDBTableSource.java |  4 +-
 .../{MongoRowKind.java => MongoDBRowKind.java}     | 14 +++--
 ...Validator.java => MongoDBRowKindValidator.java} | 19 +++++--
 5 files changed, 72 insertions(+), 41 deletions(-)
 rename inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/table/filter/{MongoRowKind.java => MongoDBRowKind.java} (85%)
 rename inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/table/filter/{RowKindValidator.java => MongoDBRowKindValidator.java} (74%)