We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ded2c17 commit 64c0c86Copy full SHA for 64c0c86
1 file changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteDistinctAggregates.scala
@@ -241,7 +241,7 @@ object RewriteDistinctAggregates extends Rule[LogicalPlan] {
241
groupByAttrs ++ distinctAggChildAttrs ++ Seq(gid) ++ regularAggChildAttrMap.map(_._2),
242
a.child)
243
244
- // Construct the first aggregate operator. This de-duplicates the all the children of
+ // Construct the first aggregate operator. This de-duplicates all the children of
245
// distinct operators, and applies the regular aggregate operators.
246
val firstAggregateGroupBy = groupByAttrs ++ distinctAggChildAttrs :+ gid
247
val firstAggregate = Aggregate(
0 commit comments