[mongodb][hotfix] Fix SourceRecord range check (#2343)

(cherry picked from commit 0b9ca5958d)
2 years ago · c35b1ff3bc
parent 7bb5253465
commit c35b1ff3bc
1 changed files with 1 additions and 1 deletions
--- a/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
+++ b/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
@ -132,7 +132,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