(seatunnel) branch dev updated: [Improve][seatunnel-connectors-v2][connector-mongodb] Improve MongodbWriter close (#10051)

[lidongdai]

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

lidongdai 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 276d25132f [Improve][seatunnel-connectors-v2][connector-mongodb] 
Improve MongodbWriter close (#10051)
276d25132f is described below

commit 276d25132f96230019b76de4a800a0e87e77df87
Author: 老王 <58297137+chl-...@users.noreply.github.com>
AuthorDate: Tue Nov 11 20:36:18 2025 +0800

    [Improve][seatunnel-connectors-v2][connector-mongodb] Improve MongodbWriter 
close (#10051)
---
 .../connectors/seatunnel/mongodb/sink/MongodbWriter.java    | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriter.java
 
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriter.java
index 63ab499ccf..14fe86a696 100644
--- 
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriter.java
+++ 
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbWriter.java
@@ -151,11 +151,14 @@ public class MongodbWriter
 
     @Override
     public void close() {
-        if (!transaction) {
-            doBulkWrite();
-        }
-        if (collectionProvider != null) {
-            collectionProvider.close();
+        try {
+            if (!transaction) {
+                doBulkWrite();
+            }
+        } finally {
+            if (collectionProvider != null) {
+                collectionProvider.close();
+            }
         }
     }