fix test

apache · Mar 13, 2019 · 7b922f9 · 7b922f9
1 parent 71e6ae1
commit 7b922f9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileDataSourceV2.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileDataSourceV2.scala
@@ -44,7 +44,7 @@ trait FileDataSourceV2 extends TableProvider with DataSourceRegister {
     Option(map.get("paths")).map { pathStr =>
       objectMapper.readValue(pathStr, classOf[Array[String]]).toSeq
     }.orElse(Option(map.get("path")).map(Seq(_))).getOrElse {
-      throw new IllegalArgumentException("'path' must be given when reading files.")
+      Nil
     }
   }
 }
diff --git a/...n/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamMicroBatchStream.scala b/...n/scala/org/apache/spark/sql/execution/streaming/sources/RateStreamMicroBatchStream.scala
@@ -155,7 +155,7 @@ class RateStreamMicroBatchStream(
 
   override def toString: String = s"RateStreamV2[rowsPerSecond=$rowsPerSecond, " +
     s"rampUpTimeSeconds=$rampUpTimeSeconds, " +
-    s"numPartitions=${Option(options.get(NUM_PARTITIONS)).getOrElse("default")}"
+    s"numPartitions=${options.getOrDefault(NUM_PARTITIONS, "default")}"
 }
 
 case class RateStreamMicroBatchInputPartition(