aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWenchen Fan <cloud0fan@outlook.com>2015-08-17 11:36:18 -0700
committerMichael Armbrust <michael@databricks.com>2015-08-17 11:36:18 -0700
commita4acdabb103f6d04603163c9555c1ddc413c3b80 (patch)
treeee3aaaeda29586f6e49625b5ab28dc3dce7552f4
parentf68d024096c90936f9aa4e325141b39f08c72476 (diff)
downloadspark-a4acdabb103f6d04603163c9555c1ddc413c3b80.tar.gz
spark-a4acdabb103f6d04603163c9555c1ddc413c3b80.tar.bz2
spark-a4acdabb103f6d04603163c9555c1ddc413c3b80.zip
[SPARK-9950] [SQL] Wrong Analysis Error for grouping/aggregating on struct fields
This issue has been fixed by https://github.com/apache/spark/pull/8215, this PR added regression test for it. Author: Wenchen Fan <cloud0fan@outlook.com> Closes #8222 from cloud-fan/minor and squashes the following commits: 0bbfb1c [Wenchen Fan] fix style... 7e2d8d9 [Wenchen Fan] add test
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala5
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
index cf22797752..1e2aaae52c 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
@@ -873,4 +873,9 @@ class DataFrameSuite extends QueryTest with SharedSQLContext {
"""{"a": {"b": 1}}""" :: Nil))
checkAnswer(df.orderBy("a.b"), Row(Row(1)))
}
+
+ test("SPARK-9950: correctly analyze grouping/aggregating on struct fields") {
+ val df = Seq(("x", (1, 1)), ("y", (2, 2))).toDF("a", "b")
+ checkAnswer(df.groupBy("b._1").agg(sum("b._2")), Row(1, 1) :: Row(2, 2) :: Nil)
+ }
}