This is an automated email from the ASF dual-hosted git repository.
agrove 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 b63570b7 fix: use inputRDD to get outputPartitions in CometScanExec
(#1162)
b63570b7 is described below
commit b63570b78ff0b9e6719eea55b4fad13153663757
Author: Parth Chandra <[email protected]>
AuthorDate: Wed Dec 11 14:01:26 2024 -0800
fix: use inputRDD to get outputPartitions in CometScanExec (#1162)
---
spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala
b/spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala
index 49f7694b..177278e6 100644
--- a/spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala
+++ b/spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala
@@ -132,7 +132,7 @@ case class CometScanExec(
lazy val bucketedScan: Boolean = wrapped.bucketedScan
override lazy val (outputPartitioning, outputOrdering): (Partitioning,
Seq[SortOrder]) =
- (wrapped.outputPartitioning, wrapped.outputOrdering)
+ (UnknownPartitioning(wrapped.inputRDD.getNumPartitions),
wrapped.outputOrdering)
@transient
private lazy val pushedDownFilters = getPushedDownFilters(relation,
dataFilters)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
