Throw a better error if path is not specified

apache · Feb 8, 2016 · fb0e3f9 · fb0e3f9
1 parent 1ffee5f
commit fb0e3f9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala
@@ -203,7 +203,9 @@ trait HadoopFsRelationProvider extends StreamSourceProvider {
       schema: Option[StructType],
       providerName: String,
       parameters: Map[String, String]): Source = {
-    val path = parameters("path")
+    val path = parameters.getOrElse("path", {
+      throw new IllegalArgumentException("'path' is not specified")
+    })
     val metadataPath = parameters.getOrElse("metadataPath", s"$path/_metadata")
 
     def dataFrameBuilder(files: Array[String]): DataFrame = {