Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19823#discussion_r153080935
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala
---
@@ -2624,7 +2624,13 @@ class SQLQuerySuite extends QueryTest with
SharedSQLContext {
val e = intercept[AnalysisException](sql("SELECT nvl(1, 2, 3)"))
assert(e.message.contains("Invalid number of arguments"))
}
-
+ test("load command invalid path validation ") {
+ withTable("tbl") {
+ sql("CREATE TABLE tbl(i INT, j STRING) USING parquet")
+ val e = intercept[AnalysisException](sql("load data inpath
'hdfs://localhost/doesnotexist.csv' into table tbl"))
+ assert(e.message.contains("LOAD DATA input path does not exist"))
--- End diff --
indents between 2629 and 2631
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
