Skip to content

Commit 124ad87

Browse files
committed
Refine test
1 parent a8cb828 commit 124ad87

File tree

1 file changed

+13
-13
lines changed

1 file changed

+13
-13
lines changed

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

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -3235,27 +3235,27 @@ class SQLQuerySuite extends QueryTest with SharedSparkSession {
32353235
}
32363236

32373237
test("SPARK-29213: FilterExec should not throw NPE") {
3238-
withView("t1", "t2", "t3") {
3239-
sql("select ''").as[String].map(identity).toDF("x").createOrReplaceTempView("t1")
3240-
sql("select * from values 0, cast(null as bigint)")
3238+
withTempView("t1", "t2", "t3") {
3239+
sql("SELECT ''").as[String].map(identity).toDF("x").createOrReplaceTempView("t1")
3240+
sql("SELECT * FROM VALUES 0, CAST(NULL AS BIGINT)")
32413241
.as[java.lang.Long]
32423242
.map(identity)
32433243
.toDF("x")
32443244
.createOrReplaceTempView("t2")
3245-
sql("select ''").as[String].map(identity).toDF("x").createOrReplaceTempView("t3")
3245+
sql("SELECT ''").as[String].map(identity).toDF("x").createOrReplaceTempView("t3")
32463246
sql(
32473247
"""
3248-
|select t1.x
3249-
|from t1
3250-
|left join (
3251-
| select x from (
3252-
| select x from t2
3253-
| union all
3254-
| select substr(x,5) x from t3
3248+
|SELECT t1.x
3249+
|FROM t1
3250+
|LEFT JOIN (
3251+
| SELECT x FROM (
3252+
| SELECT x FROM t2
3253+
| UNION ALL
3254+
| SELECT SUBSTR(x,5) x FROM t3
32553255
| ) a
3256-
| where length(x)>0
3256+
| WHERE LENGTH(x)>0
32573257
|) t3
3258-
|on t1.x=t3.x
3258+
|ON t1.x=t3.x
32593259
""".stripMargin).collect()
32603260
}
32613261
}

0 commit comments

Comments
 (0)