Skip to content

Commit bc1b7e5

Browse files
committed
update2
1 parent 4dcc1b1 commit bc1b7e5

File tree

1 file changed

+1
-1
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate

1 file changed

+1
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/interfaces.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -405,7 +405,7 @@ abstract class DeclarativeAggregate
405405
// the aggregate function will be transformed to a new copied node during `PlanSubqueries` and
406406
// lost original attributes because `TreeNode` does not preserve "lazy val" during `makeCopy`.
407407
// As a result, the final agg could fail to resolve references through partial agg. So we use
408-
// the tag to save the original attributes to let the new copy node share the same attributes
408+
// the tag to save the original attributes to let the new copied node share the same attributes
409409
// with old node.
410410
getTagValue(inputAggBufferAttributeTag).getOrElse {
411411
val attrs = aggBufferAttributes.map(_.newInstance())

0 commit comments

Comments
 (0)