We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 17bdb32 commit 063c463Copy full SHA for 063c463
core/src/main/java/org/apache/iceberg/BaseTransaction.java
@@ -376,11 +376,11 @@ private void commitSimpleTransaction() {
376
throw e;
377
378
} catch (PendingUpdateFailedException e) {
379
- cleanUpOnCommitFailure();
+ cleanUp();
380
throw e.wrapped();
381
} catch (RuntimeException e) {
382
if (!ops.requireStrictCleanup() || e instanceof CleanableFailure) {
383
384
}
385
386
@@ -417,7 +417,7 @@ private void commitSimpleTransaction() {
417
418
419
420
- private void cleanUpOnCommitFailure() {
+ protected void cleanUp() {
421
// the commit failed and no files were committed. clean up each update.
422
cleanAllUpdates();
423
0 commit comments