[Fix][Connector-Mongodb] close MongodbClient when close MongodbReader (…

…apache#8592) Co-authored-by: binwang219962 <[email protected]>
liunaijie · Jan 27, 2025 · 06b2fc0 · 06b2fc0
1 parent a3513eb
commit 06b2fc0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...n/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java b/...n/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
@@ -82,6 +82,9 @@ public void close() {
         if (cursor != null) {
             cursor.close();
         }
+        if (clientProvider != null) {
+            clientProvider.close();
+        }
     }
 
     @Override