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 97e66f14f56..2b234bdd76a 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 void abortPrepare() {}
 
     @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();
         }
     }
 }