This is an automated email from the ASF dual-hosted git repository.

jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 4573e3e09 [AMORO-3703] Use dataFileFormat for deleteFile if not set 
(#3704)
4573e3e09 is described below

commit 4573e3e0978635fa935d7ef479c8e75f8198af73
Author: Marig_Weizhi <[email protected]>
AuthorDate: Fri Aug 1 10:13:24 2025 +0800

    [AMORO-3703] Use dataFileFormat for deleteFile if not set (#3704)
    
    Use data file format for delete file if not set
---
 .../org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java
 
b/amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java
index aec52b0dc..931fadc07 100644
--- 
a/amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java
+++ 
b/amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java
@@ -167,8 +167,10 @@ public abstract class AbstractRewriteFilesExecutor
   }
 
   protected FileFormat deleteFileFormat() {
+    String dataFileFormatName =
+        table.properties().getOrDefault(DEFAULT_FILE_FORMAT, 
DEFAULT_FILE_FORMAT_DEFAULT);
     String deleteFileFormatName =
-        table.properties().getOrDefault(DELETE_DEFAULT_FILE_FORMAT, 
DEFAULT_FILE_FORMAT_DEFAULT);
+        table.properties().getOrDefault(DELETE_DEFAULT_FILE_FORMAT, 
dataFileFormatName);
     return FileFormat.valueOf(deleteFileFormatName.toUpperCase());
   }
 

Reply via email to