diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala index 7b978c9860..0cd4b3d9cd 100644 --- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala +++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala @@ -3222,7 +3222,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim val fileBuilder = OperatorOuterClass.SparkPartitionedFile.newBuilder() partitionVals.foreach(fileBuilder.addPartitionValues) fileBuilder - .setFilePath(file.pathUri.toString) + .setFilePath(file.filePath.toUri.toString) .setStart(file.start) .setLength(file.length) .setFileSize(file.fileSize)