Skip to content

Commit 6b2d609

Browse files
committed
address comments.
1 parent 2c72edf commit 6b2d609

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DataFrameComplexTypeSuite.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ class DataFrameComplexTypeSuite extends QueryTest with SharedSQLContext {
3030
val f = udf((a: String) => a)
3131
val df = sparkContext.parallelize(Seq((1, 1))).toDF("a", "b")
3232
df.select(struct($"a").as("s")).select(f($"s.a")).collect()
33-
df.select(struct($"*").as("s")).select(f($"s.a")).collect()
3433
}
3534

3635
test("UDF on named_struct") {
@@ -43,7 +42,6 @@ class DataFrameComplexTypeSuite extends QueryTest with SharedSQLContext {
4342
val f = udf((a: String) => a)
4443
val df = sparkContext.parallelize(Seq((1, 1))).toDF("a", "b")
4544
df.select(array($"a").as("s")).select(f(expr("s[0]"))).collect()
46-
df.select(array($"*").as("s")).select(f(expr("s[0]"))).collect()
4745
}
4846

4947
test("SPARK-12477 accessing null element in array field") {

sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1946,11 +1946,11 @@ class SQLQuerySuite extends QueryTest with SharedSQLContext {
19461946

19471947
// CreateStruct and CreateArray in project list (unresolved alias)
19481948
assert(structDf.select(struct($"record.*")).first() == Row(Row(1, 1)))
1949-
assert(structDf.select(array($"record.*")).first().getAs[Seq[Int]](0) === Array(1, 1))
1949+
assert(structDf.select(array($"record.*")).first().getAs[Seq[Int]](0) === Seq(1, 1))
19501950

19511951
// CreateStruct and CreateArray in project list (alias)
19521952
assert(structDf.select(struct($"record.*").as("a")).first() == Row(Row(1, 1)))
1953-
assert(structDf.select(array($"record.*").as("a")).first().getAs[Seq[Int]](0) === Array(1, 1))
1953+
assert(structDf.select(array($"record.*").as("a")).first().getAs[Seq[Int]](0) === Seq(1, 1))
19541954
}
19551955

19561956
test("Common subexpression elimination") {

0 commit comments

Comments
 (0)