File tree Expand file tree Collapse file tree 1 file changed +13
-13
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +13
-13
lines changed Original file line number Diff line number Diff 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 }
You can’t perform that action at this time.
0 commit comments