From 0b9ca5958de3f5f5fbe0eb740d30e2fa367a3aef Mon Sep 17 00:00:00 2001
From: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
Date: Wed, 26 Jul 2023 14:07:05 +0800
Subject: [PATCH] [mongodb][hotfix] Fix SourceRecord range check (#2343)

---
 .../mongodb/source/reader/fetch/MongoDBFetchTaskContext.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 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
index f063c332e0..23d97c0c5f 100644
--- 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 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