Skip to content

Commit 06b2fc0

Browse files
sohurdcbinwang219962
andauthored
[Fix][Connector-Mongodb] close MongodbClient when close MongodbReader (#8592)
Co-authored-by: binwang219962 <[email protected]>
1 parent a3513eb commit 06b2fc0

File tree

1 file changed

+3
-0
lines changed
  • seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader

1 file changed

+3
-0
lines changed

seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/reader/MongodbReader.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,9 @@ public void close() {
8282
if (cursor != null) {
8383
cursor.close();
8484
}
85+
if (clientProvider != null) {
86+
clientProvider.close();
87+
}
8588
}
8689

8790
@Override

0 commit comments

Comments
 (0)