From 9176544b2dbe0d26d518f9e36b3d33cdec91f145 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 | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/java/org/apache/iceberg/BaseTransaction.java b/core/src/main/java/org/apache/iceberg/BaseTransaction.java index 61da776f4c44..dc0dc67b3fa2 100644 --- 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);