From ffed1ad10e85fc369b86b18fa7fa0d192651861d Mon Sep 17 00:00:00 2001 From: amogh-jahagirdar Date: Thu, 7 Sep 2023 08:27:57 -0700 Subject: [PATCH] Core: Clear deleted files set between commit attempts for simple transaction --- core/src/main/java/org/apache/iceberg/BaseTransaction.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/main/java/org/apache/iceberg/BaseTransaction.java b/core/src/main/java/org/apache/iceberg/BaseTransaction.java index 61da776f4c44..18b6da44b193 100644 --- 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 {