fix

apache · Jun 17, 2023 · 1437a2d · 1437a2d
1 parent 9408a78
commit 1437a2d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/...ache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java b/...ache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbFetchTaskContext.java
@@ -35,7 +35,6 @@
 import org.bson.BsonValue;
 import org.jetbrains.annotations.NotNull;
 
-import com.mongodb.client.MongoClient;
 import com.mongodb.client.model.changestream.OperationType;
 import io.debezium.connector.base.ChangeEventQueue;
 import io.debezium.pipeline.DataChangeEvent;
@@ -200,13 +199,6 @@ record -> {
     @Override
     public void close() {
         Runtime.getRuntime()
-                .addShutdownHook(
-                        new Thread(
-                                () -> {
-                                    MongoClient mongoClient = createMongoClient(sourceConfig);
-                                    if (mongoClient != null) {
-                                        mongoClient.close();
-                                    }
-                                }));
+                .addShutdownHook(new Thread(() -> createMongoClient(sourceConfig).close()));
     }
 }
diff --git a/.../apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbScanFetchTask.java b/.../apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbScanFetchTask.java
@@ -208,7 +208,7 @@ public boolean isRunning() {
 
     @Override
     public void shutdown() {
-        // taskRunning = false;
+        taskRunning = false;
     }
 
     @Override