Skip to content

Commit 9f95e8b

Browse files
authored
fix: correct missingInput for CometHashAggregateExec (#2409)
1 parent 24f5209 commit 9f95e8b

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -706,6 +706,8 @@ case class CometHashAggregateExec(
706706
override val serializedPlanOpt: SerializedPlan)
707707
extends CometUnaryExec
708708
with PartitioningPreservingUnaryExecNode {
709+
override def producedAttributes: AttributeSet = outputSet ++ AttributeSet(resultExpressions)
710+
709711
override protected def withNewChildInternal(newChild: SparkPlan): SparkPlan =
710712
this.copy(child = newChild)
711713

0 commit comments

Comments
 (0)