This is an automated email from the ASF dual-hosted git repository.
viirya pushed a commit to branch comet-parquet-exec
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/comet-parquet-exec by this
push:
new 4de51a8a fix: Use filePath instead of pathUri (#1124)
4de51a8a is described below
commit 4de51a8aa10792218ddfc53a7234282ebda11350
Author: Liang-Chi Hsieh <[email protected]>
AuthorDate: Fri Nov 29 14:18:57 2024 -0800
fix: Use filePath instead of pathUri (#1124)
---
spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala | 2 +-
1 file changed, 1 insertion(+), 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
index 7b978c98..0cd4b3d9 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
