This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 945e844240 [INLONG-8594][Sort] Fix SourceRecord range check of
Mongodb CDC (#8595)
945e844240 is described below
commit 945e844240ab6412253e1e3b49b6ec9a95364153
Author: emhui <[email protected]>
AuthorDate: Thu Jul 27 18:07:11 2023 +0800
[INLONG-8594][Sort] Fix SourceRecord range check of Mongodb CDC (#8595)
---
.../sort/cdc/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
index 9db87f5aa9..4eee81a77c 100644
---
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
+++
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
@@ -130,7 +130,7 @@ public class MongoDBFetchTaskContext implements
FetchTask.Context {
BsonDocument splitKeys = (BsonDocument) splitStart[0];
String firstKey = splitKeys.getFirstKey();
BsonValue keyValue = documentKey.get(firstKey);
- BsonValue lowerBound = ((BsonDocument) splitEnd[1]).get(firstKey);
+ BsonValue lowerBound = ((BsonDocument) splitStart[1]).get(firstKey);
BsonValue upperBound = ((BsonDocument) splitEnd[1]).get(firstKey);
// for all range
