From eca26c2af120cc154feba71b010f1e18ada9728e Mon Sep 17 00:00:00 2001
From: Hongshun Wang <loserwang1024@gmail.com>
Date: Tue, 23 Jan 2024 14:25:53 +0800
Subject: [PATCH] [cdc-connector][mongodb][hotfix] Stop executing log reading
 in MongoDBStreamFetchTask.close (#3029)

---
 .../mongodb/source/reader/fetch/MongoDBStreamFetchTask.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
index 38575278ba9..eebdc575ac9 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/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) {