(seatunnel) branch dev updated: [Hotfix][Connector-V2] Release resources when task is closed for iceberg sinkwriter (#7729)

[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 ff281183bd [Hotfix][Connector-V2] Release resources when task is 
closed for iceberg sinkwriter (#7729)
ff281183bd is described below

commit ff281183bd6fe4be571c8b4c7a2e3529a2fd291c
Author: dailai <dai...@chinatelecom.cn>
AuthorDate: Tue Sep 24 11:50:53 2024 +0800

    [Hotfix][Connector-V2] Release resources when task is closed for iceberg 
sinkwriter (#7729)
---
 .../connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java
 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java
index a5b25a216c..6f31626913 100644
--- 
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java
+++ 
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java
@@ -146,7 +146,15 @@ public class IcebergSinkWriter
     public void abortPrepare() {}
 
     @Override
-    public void close() throws IOException {}
+    public void close() throws IOException {
+        try {
+            if (writer != null) {
+                writer.close();
+            }
+        } finally {
+            results.clear();
+        }
+    }
 
     private String fieldsInfo(SeaTunnelRowType seaTunnelRowType) {
         String[] fieldsInfo = new String[seaTunnelRowType.getTotalFields()];