(seatunnel) branch dev updated: [Hotfix][Connector-V2] Release resources even the task is crashed for paimon sink (#7726)

[wanghailin]

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

wanghailin 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 5ddf8d461e [Hotfix][Connector-V2] Release resources even the task is 
crashed for paimon sink (#7726)
5ddf8d461e is described below

commit 5ddf8d461e73d81d076fb00401280f8042feceea
Author: dailai <dai...@chinatelecom.cn>
AuthorDate: Tue Sep 24 11:49:32 2024 +0800

    [Hotfix][Connector-V2] Release resources even the task is crashed for 
paimon sink (#7726)
---
 .../seatunnel/paimon/sink/PaimonSinkWriter.java          | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
 
b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
index 97e66f14f5..2b234bdd76 100644
--- 
a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
+++ 
b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
@@ -205,13 +205,17 @@ public class PaimonSinkWriter
 
     @Override
     public void close() throws IOException {
-        if (Objects.nonNull(tableWrite)) {
-            try {
-                tableWrite.close();
-            } catch (Exception e) {
-                log.error("Failed to close table writer in paimon sink 
writer.", e);
-                throw new SeaTunnelException(e);
+        try {
+            if (Objects.nonNull(tableWrite)) {
+                try {
+                    tableWrite.close();
+                } catch (Exception e) {
+                    log.error("Failed to close table writer in paimon sink 
writer.", e);
+                    throw new SeaTunnelException(e);
+                }
             }
+        } finally {
+            committables.clear();
         }
     }
 }