We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
missingInput
CometHashAggregateExec
1 parent 24f5209 commit 9f95e8bCopy full SHA for 9f95e8b
1 file changed
spark/src/main/scala/org/apache/spark/sql/comet/operators.scala
@@ -706,6 +706,8 @@ case class CometHashAggregateExec(
706
override val serializedPlanOpt: SerializedPlan)
707
extends CometUnaryExec
708
with PartitioningPreservingUnaryExecNode {
709
+ override def producedAttributes: AttributeSet = outputSet ++ AttributeSet(resultExpressions)
710
+
711
override protected def withNewChildInternal(newChild: SparkPlan): SparkPlan =
712
this.copy(child = newChild)
713
0 commit comments