fix: Use filePath instead of pathUri

viirya · Nov 27, 2024 · 76af6ca · 76af6ca
1 parent c3ad26e
commit 76af6ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)