Core: Clear deleted files set between commit attempts for simple tran…

…saction
apache · Sep 7, 2023 · 9176544 · 9176544
1 parent 38e1c33
commit 9176544
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/java/org/apache/iceberg/BaseTransaction.java b/core/src/main/java/org/apache/iceberg/BaseTransaction.java
@@ -421,6 +421,7 @@ private void commitSimpleTransaction() {
           .onlyRetryOn(CommitFailedException.class)
           .run(
               underlyingOps -> {
+                deletedFiles.clear();
                 applyUpdates(underlyingOps);
 
                 underlyingOps.commit(base, current);