Skip to content

Commit efa9b03

Browse files
committed
Update HiveQuerySuite.scala
1 parent 72accf1 commit efa9b03

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -413,12 +413,14 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
413413
createQueryTest("select null from table",
414414
"SELECT null FROM src LIMIT 1")
415415

416-
createQueryTest("predicates contains an empty AttributeSet() references",
417-
"""
418-
|SELECT a FROM (
419-
| SELECT 1 AS a FROM src LIMIT 1 ) table
420-
|WHERE abs(20141202) is not null
421-
""".stripMargin)
416+
test("predicates contains an empty AttributeSet() references") {
417+
sql(
418+
"""
419+
|SELECT a FROM (
420+
| SELECT 1 AS a FROM src LIMIT 1 ) table
421+
|WHERE abs(20141202) is not null
422+
""".stripMargin).collect()
423+
}
422424

423425
test("implement identity function using case statement") {
424426
val actual = sql("SELECT (CASE key WHEN key THEN key END) FROM src")

0 commit comments

Comments
 (0)