File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -367,9 +367,9 @@ object MultipleDistinctRewriter extends Rule[LogicalPlan] {
367367 val patchedAggExpressions = a.aggregateExpressions.map { e =>
368368 e.transformDown {
369369 case e : Expression =>
370- // GROUP BY can be different in form () but must be semantically equal. This makes
371- // a map lookup tricky. So we do a linear search for a semantically equal group by
372- // expression.
370+ // The same GROUP BY clauses can have different forms (different names for instance) in
371+ // the groupBy and aggregate expressions of an aggregate. This makes a map lookup
372+ // tricky. So we do a linear search for a semantically equal group by expression.
373373 groupByMap
374374 .find(ge => e.semanticEquals(ge._1))
375375 .map(_._2)
You can’t perform that action at this time.
0 commit comments