Skip to content

Commit d986ddc

Browse files
committed
Simplify test
1 parent 55c64ca commit d986ddc

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -819,8 +819,6 @@ class SubquerySuite extends QueryTest with SharedSQLContext {
819819
Seq((1, 1), (2, 0)).toDF("c1", "c2").createOrReplaceTempView("t1")
820820
Seq[(Int, Array[Int])]((1, Array(1, 2)), (2, Array(-1, -3)))
821821
.toDF("c1", "arr_c2").createTempView("t2")
822-
Seq[(Int, Array[Int])]((1, Array(1, 2)), (2, Array(-1, -3)))
823-
.toDF("c1", "arr_c2").createTempView("t3")
824822
checkAnswer(
825823
sql(
826824
"""
@@ -835,10 +833,10 @@ class SubquerySuite extends QueryTest with SharedSQLContext {
835833
sql(
836834
"""
837835
| select c1
838-
| from t3
836+
| from t2
839837
| where exists (select *
840-
| from t2 lateral view explode(t3.arr_c2) q as c2
841-
| where t3.c1 = t2.c1)
838+
| from t1 lateral view explode(t2.arr_c2) q as c2
839+
| where t1.c1 = t2.c1)
842840
""".stripMargin)
843841
}
844842
assert(msg1.getMessage.contains(

0 commit comments

Comments
 (0)