fix file path constant bug (#58)

apache · Jul 22, 2022 · 5bdcf29 · 5bdcf29
1 parent 6b4835a
commit 5bdcf29
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/java/com/netease/arctic/io/reader/DataReaderCommon.java b/core/src/main/java/com/netease/arctic/io/reader/DataReaderCommon.java
@@ -23,7 +23,8 @@ public class DataReaderCommon {
     if (!partitionSchema.columns().isEmpty()) {
       idToConstant.putAll(PartitionUtil.constantsMap(task, convertConstant));
     }
-    idToConstant.put(org.apache.iceberg.MetadataColumns.FILE_PATH.fieldId(), task.file().path().toString());
+    idToConstant.put(org.apache.iceberg.MetadataColumns.FILE_PATH.fieldId(),
+        convertConstant.apply(Types.StringType.get(), task.file().path().toString()));
     idToConstant.put(
         MetadataColumns.TRANSACTION_ID_FILED_ID,
         convertConstant.apply(Types.LongType.get(), task.file().transactionId()));