Skip to content

Commit e2b0253

Browse files
committed
fix: correct missingInput for CometHashAggregateExec
1 parent 5565a6a commit e2b0253

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
@@ -692,6 +692,8 @@ case class CometHashAggregateExec(
692692
override val serializedPlanOpt: SerializedPlan)
693693
extends CometUnaryExec
694694
with PartitioningPreservingUnaryExecNode {
695+
override def producedAttributes: AttributeSet = outputSet ++ AttributeSet(resultExpressions)
696+
695697
override protected def withNewChildInternal(newChild: SparkPlan): SparkPlan =
696698
this.copy(child = newChild)
697699

0 commit comments

Comments
 (0)