(fluss) branch main updated: [lake] Avoid aborting Paimon commit after failure (#3370)

[yuxia]

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

luoyuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 0bac6272c [lake] Avoid aborting Paimon commit after failure (#3370)
0bac6272c is described below

commit 0bac6272ca8f7e870b128137300b48cc63e45db3
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Mon May 25 14:46:58 2026 +0800

    [lake] Avoid aborting Paimon commit after failure (#3370)
---
 .../org/apache/fluss/lake/paimon/tiering/PaimonLakeCommitter.java     | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
 
b/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
index bae9da3b3..339ec2b2b 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
@@ -153,10 +153,6 @@ public class PaimonLakeCommitter implements 
LakeCommitter<PaimonWriteResult, Pai
             }
 
         } catch (Throwable t) {
-            if (tableCommit != null) {
-                // if any error happen while commit, abort the commit to clean 
committable
-                tableCommit.abort(manifestCommittable.fileCommittables());
-            }
             throw new IOException(t);
         }
     }