fix unitest exception

apache · Dec 21, 2023 · d24488a · d24488a
1 parent 1b0553b
commit d24488a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/data/src/main/java/org/apache/iceberg/data/GenericAppenderFactory.java b/data/src/main/java/org/apache/iceberg/data/GenericAppenderFactory.java
@@ -136,7 +136,7 @@ public org.apache.iceberg.io.DataWriter<Record> newDataWriter(
     return new org.apache.iceberg.io.DataWriter<>(
         newAppender(file, format),
         format,
-        file.plainOutputFile().location(),
+        file.encryptingOutputFile().location(),
         spec,
         partition,
         file.keyMetadata());

diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkAppenderFactory.java
@@ -152,7 +152,7 @@ public DataWriter<RowData> newDataWriter(
     return new DataWriter<>(
         newAppender(file, format),
         format,
-        file.plainOutputFile().location(),
+        file.encryptingOutputFile().location(),
         spec,
         partition,
         file.keyMetadata());

diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkAppenderFactory.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkAppenderFactory.java
@@ -211,7 +211,7 @@ public DataWriter<InternalRow> newDataWriter(
     return new DataWriter<>(
         newAppender(file, format),
         format,
-        file.plainOutputFile().location(),
+        file.encryptingOutputFile().location(),
         spec,
         partition,
         file.keyMetadata());