diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala index 89e30b83784cf..68d059e938547 100755 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala @@ -149,6 +149,7 @@ class SqlParser extends StandardTokenParsers with PackratParsers { grpExprs: Seq[Expression], projExprs: Seq[Expression]): Seq[NamedExpression] = { grpExprs.zipWithIndex.map { + case (ne: NamedExpression, _) => ne case (e, i) => var aliasForGrp:NamedExpression = null projExprs.foreach { diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala index 32ad9bd35f6f7..13ac3d4710e7c 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala @@ -676,7 +676,5 @@ class SQLQuerySuite extends QueryTest with BeforeAndAfterAll { test("SPARK-3371 Renaming a function expression with group by gives error") { registerFunction("len", (s: String) => s.length) checkAnswer( - sql("SELECT len(value) as temp FROM testData WHERE key = 1 group by len(value)"), - Seq(Seq("1"))) - } + sql("SELECT len(value) as temp FROM testData WHERE key = 1 group by len(value)"), 1)} }