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());
}