From e0b8386f6da85e713a81c3978380c4c76e886402 Mon Sep 17 00:00:00 2001 From: Simeon Simeonov Date: Mon, 20 Jul 2015 23:33:40 -0400 Subject: [PATCH] SPARK-9210 corrects aggregate function name in exception message --- .../org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala index c7f9713344c50..0f1855d34996f 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala @@ -89,7 +89,8 @@ trait CheckAnalysis { failAnalysis( s"expression '${e.prettyString}' is neither present in the group by, " + s"nor is it an aggregate function. " + - "Add to group by or wrap in first() if you don't care which value you get.") + s"Add to group by or wrap in first_value() " + + "if you don't care which value you get.") case e if groupingExprs.exists(_.semanticEquals(e)) => // OK case e if e.references.isEmpty => // OK case e => e.children.foreach(checkValidAggregateExpression)