[cdc-connector][mongodb][hotfix] Stop executing log reading in MongoD…

…BStreamFetchTask.close (#3029)
apache · Jan 23, 2024 · eca26c2 · eca26c2
1 parent 9ce3656
commit eca26c2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java b/...java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
@@ -225,7 +225,9 @@ public StreamSplit getSplit() {
     }
 
     @Override
-    public void close() {}
+    public void close() {
+        taskRunning = false;
+    }
 
     private MongoChangeStreamCursor<BsonDocument> openChangeStreamCursor(
             ChangeStreamDescriptor changeStreamDescriptor) {