(seatunnel) branch dev updated: [Fix][Connector-Mongodb] close MongodbClient when close MongodbReader (#8592)

[liugddx]

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

liugddx 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 06b2fc0e06 [Fix][Connector-Mongodb] close MongodbClient when close 
MongodbReader (#8592)
06b2fc0e06 is described below

commit 06b2fc0e06ec2a478e448c5cfa0047e2f69531ba
Author: sohurdc <bigdata...@sohu-inc.com>
AuthorDate: Mon Jan 27 21:36:10 2025 +0800

    [Fix][Connector-Mongodb] close MongodbClient when close MongodbReader 
(#8592)
    
    Co-authored-by: binwang219962 <binwang219...@sohu-inc.com>
---
 .../connectors/seatunnel/mongodb/source/reader/MongodbReader.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
 
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
index e55fa5c876..84f7575ad5 100644
--- 
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
+++ 
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java
@@ -82,6 +82,9 @@ public class MongodbReader implements 
SourceReader<SeaTunnelRow, MongoSplit> {
         if (cursor != null) {
             cursor.close();
         }
+        if (clientProvider != null) {
+            clientProvider.close();
+        }
     }
 
     @Override