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 06cdd22e Revert "fix: use inputRDD to get outputPartitions in
CometScanExec (#1162)"
06cdd22e is described below
commit 06cdd22e664d6e501d15e9563e1c9570f0e9d0f0
Author: Andy Grove <[email protected]>
AuthorDate: Thu Dec 12 16:02:22 2024 -0700
Revert "fix: use inputRDD to get outputPartitions in CometScanExec (#1162)"
This reverts commit b63570b78ff0b9e6719eea55b4fad13153663757.
---
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 177278e6..49f7694b 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]) =
- (UnknownPartitioning(wrapped.inputRDD.getNumPartitions),
wrapped.outputOrdering)
+ (wrapped.outputPartitioning, wrapped.outputOrdering)
@transient
private lazy val pushedDownFilters = getPushedDownFilters(relation,
dataFilters)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
