File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -85,8 +85,9 @@ class CheckAnalysis {
8585
8686 cleaned.foreach(checkValidAggregateExpression)
8787
88- case o if o.children.nonEmpty && o.missingInput.nonEmpty =>
89- val missingAttributes = o.missingInput.map(_.prettyString).mkString(" ," )
88+ case o if o.children.nonEmpty &&
89+ ! o.references.filter(_.name != " grouping__id" ).subsetOf(o.inputSet) =>
90+ val missingAttributes = (o.references -- o.inputSet).map(_.prettyString).mkString(" ," )
9091 val input = o.inputSet.map(_.prettyString).mkString(" ," )
9192
9293 failAnalysis(s " resolved attributes $missingAttributes missing from $input" )
Original file line number Diff line number Diff line change @@ -191,8 +191,6 @@ case class Expand(
191191 val sizeInBytes = child.statistics.sizeInBytes * projections.length
192192 Statistics (sizeInBytes = sizeInBytes)
193193 }
194-
195- override def missingInput = super .missingInput.filter(_.name != VirtualColumn .groupingIdName)
196194}
197195
198196trait GroupingAnalytics extends UnaryNode {
You can’t perform that action at this time.
0 commit comments