Spark: Fix Puffin suffix for DVs

apache · Jan 17, 2025 · c354dbe · c354dbe
1 parent 3247964
commit c354dbe
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
@@ -214,6 +214,10 @@ private boolean fanoutWriterEnabled(boolean defaultValue) {
   }
 
   public FileFormat deleteFileFormat() {
+    if (useDVs()) {
+      return FileFormat.PUFFIN;
+    }
+
     String valueAsString =
         confParser
             .stringConf()