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

apache · Jul 26, 2023 · 0b9ca59 · 0b9ca59
1 parent bca60a4
commit 0b9ca59
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java b/...ava/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBFetchTaskContext.java
@@ -132,7 +132,7 @@ public boolean isRecordBetween(SourceRecord record, Object[] splitStart, Object[
         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