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

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


The following commit(s) were added to refs/heads/main by this push:
     new 063c463fe2 Core: Rename cleanUpOnCommitFailure to cleanUp and make it 
protected (#15389)
063c463fe2 is described below

commit 063c463fe27692fb0fa8ea249d02015cc31cae9d
Author: Denys Kuzmenko <[email protected]>
AuthorDate: Mon Mar 16 13:46:06 2026 +0200

    Core: Rename cleanUpOnCommitFailure to cleanUp and make it protected 
(#15389)
---
 core/src/main/java/org/apache/iceberg/BaseTransaction.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/core/src/main/java/org/apache/iceberg/BaseTransaction.java 
b/core/src/main/java/org/apache/iceberg/BaseTransaction.java
index 395bd2c1ae..9884ac2970 100644
--- a/core/src/main/java/org/apache/iceberg/BaseTransaction.java
+++ b/core/src/main/java/org/apache/iceberg/BaseTransaction.java
@@ -376,11 +376,11 @@ public class BaseTransaction implements Transaction {
       throw e;
 
     } catch (PendingUpdateFailedException e) {
-      cleanUpOnCommitFailure();
+      cleanUp();
       throw e.wrapped();
     } catch (RuntimeException e) {
       if (!ops.requireStrictCleanup() || e instanceof CleanableFailure) {
-        cleanUpOnCommitFailure();
+        cleanUp();
       }
 
       throw e;
@@ -417,7 +417,7 @@ public class BaseTransaction implements Transaction {
     }
   }
 
-  private void cleanUpOnCommitFailure() {
+  protected void cleanUp() {
     // the commit failed and no files were committed. clean up each update.
     cleanAllUpdates();
 

Reply via email to