diff options
author | Wenchen Fan <cloud0fan@outlook.com> | 2015-08-17 11:36:18 -0700 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2015-08-17 11:36:34 -0700 |
commit | 76390ec00a659b5e3dead0792bfe51cbb59b883b (patch) | |
tree | d7ad058c32b35dde87b8f4c6b85a90e8761cb257 /sql | |
parent | 727944564d968dbab8352958f44e2209f9d172c3 (diff) | |
download | spark-76390ec00a659b5e3dead0792bfe51cbb59b883b.tar.gz spark-76390ec00a659b5e3dead0792bfe51cbb59b883b.tar.bz2 spark-76390ec00a659b5e3dead0792bfe51cbb59b883b.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
(cherry picked from commit a4acdabb103f6d04603163c9555c1ddc413c3b80)
Signed-off-by: Michael Armbrust <michael@databricks.com>
Diffstat (limited to 'sql')
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala | 5 |
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) + } } |