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%)
