[seatunnel] branch dev updated: [Hotfix]Fix array index anomalies caused by #5057 (#5195)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 1c33429506 [Hotfix]Fix array index anomalies caused by #5057 (#5195)
1c33429506 is described below

commit 1c33429506cc81e971069ddd4460e1a355cd17d8
Author: monster <60029759+monsterchenz...@users.noreply.github.com>
AuthorDate: Tue Aug 8 19:47:24 2023 +0800

    [Hotfix]Fix array index anomalies caused by #5057 (#5195)
---
 .../seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java
index 534baa72ab..d9aee5ef97 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java
@@ -139,11 +139,11 @@ public class MongodbFetchTaskContext implements 
FetchTask.Context {
     public boolean isRecordBetween(
             SourceRecord record, @Nonnull Object[] splitStart, @Nonnull 
Object[] splitEnd) {
         BsonDocument documentKey = getDocumentKey(record);
-        BsonDocument splitKeys = (BsonDocument) ((Object[]) splitStart[0])[0];
+        BsonDocument splitKeys = (BsonDocument) splitStart[0];
         String firstKey = splitKeys.getFirstKey();
         BsonValue keyValue = documentKey.get(firstKey);
-        BsonValue lowerBound = ((BsonDocument) ((Object[]) 
splitEnd[0])[1]).get(firstKey);
-        BsonValue upperBound = ((BsonDocument) ((Object[]) 
splitEnd[0])[1]).get(firstKey);
+        BsonValue lowerBound = ((BsonDocument) splitStart[1]).get(firstKey);
+        BsonValue upperBound = ((BsonDocument) splitEnd[1]).get(firstKey);
 
         if (isFullRange(lowerBound, upperBound)) {
             return true;