Fix: fix typo, remove whitelines

apache · Jun 17, 2020 · 5f05aa7 · 5f05aa7
1 parent da7c928
commit 5f05aa7
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/HashAggregateExec.scala
@@ -340,7 +340,6 @@ case class HashAggregateExec(
     // only have DeclarativeAggregate
     val functions = aggregateExpressions.map(_.aggregateFunction.asInstanceOf[DeclarativeAggregate])
     val inputAttrs = functions.flatMap(_.aggBufferAttributes) ++ inputAttributes
-
     // To individually generate code for each aggregate function, an element in `updateExprs` holds
     // all the expressions for the buffer of an aggregation function.
     val updateExprs = aggregateExpressions.map { e =>

diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/WholeStageCodegenSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/WholeStageCodegenSuite.scala
@@ -65,7 +65,7 @@ class WholeStageCodegenSuite extends QueryTest with SharedSparkSession
       assert(partAggNode.isDefined,
       "No HashAggregate node with partial aggregate expression found")
       assert(partAggNode.get.metrics("partialAggSkipped").value == data.size,
-      "Partial aggregation got triggrered in partial hash aggregate node")
+      "Partial aggregation got triggered in partial hash aggregate node")
     }
   }