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();