Skip to content

Commit 06cdd22

Browse files
committed
Revert "fix: use inputRDD to get outputPartitions in CometScanExec (#1162)"
This reverts commit b63570b.
1 parent b63570b commit 06cdd22

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark/src/main/scala/org/apache/spark/sql/comet/CometScanExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ case class CometScanExec(
132132
lazy val bucketedScan: Boolean = wrapped.bucketedScan
133133

134134
override lazy val (outputPartitioning, outputOrdering): (Partitioning, Seq[SortOrder]) =
135-
(UnknownPartitioning(wrapped.inputRDD.getNumPartitions), wrapped.outputOrdering)
135+
(wrapped.outputPartitioning, wrapped.outputOrdering)
136136

137137
@transient
138138
private lazy val pushedDownFilters = getPushedDownFilters(relation, dataFilters)

0 commit comments

Comments
 (0)