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

…saction
apache · Sep 20, 2023 · ffed1ad · ffed1ad
1 parent 38e1c33
commit ffed1ad
Showing 1 changed file with 2 additions 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
@@ -495,6 +495,8 @@ private void applyUpdates(TableOperations underlyingOps) {
       // use refreshed the metadata
       this.base = underlyingOps.current();
       this.current = underlyingOps.current();
+      deletedFiles.clear();
+
       for (PendingUpdate update : updates) {
         // re-commit each update in the chain to apply it and update current
         try {