fix test

apache · Mar 13, 2019 · 71e6ae1 · 71e6ae1
1 parent 32fdb64
commit 71e6ae1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/util/CaseInsensitiveStringMap.java b/sql/catalyst/src/main/java/org/apache/spark/sql/util/CaseInsensitiveStringMap.java
@@ -115,7 +115,7 @@ public Set<Map.Entry<String, String>> entrySet() {
 
   /**
    * Returns the boolean value to which the specified key is mapped,
-   * or defaultValue if there is no mapping for the key. The key match is case-insensitive
+   * or defaultValue if there is no mapping for the key. The key match is case-insensitive.
    */
   public boolean getBoolean(String key, boolean defaultValue) {
     String value = get(key);
@@ -133,7 +133,7 @@ public boolean getBoolean(String key, boolean defaultValue) {
 
   /**
    * Returns the integer value to which the specified key is mapped,
-   * or defaultValue if there is no mapping for the key. The key match is case-insensitive
+   * or defaultValue if there is no mapping for the key. The key match is case-insensitive.
    */
   public int getInt(String key, int defaultValue) {
     String value = get(key);
@@ -142,7 +142,7 @@ public int getInt(String key, int defaultValue) {
 
   /**
    * Returns the long value to which the specified key is mapped,
-   * or defaultValue if there is no mapping for the key. The key match is case-insensitive
+   * or defaultValue if there is no mapping for the key. The key match is case-insensitive.
    */
   public long getLong(String key, long defaultValue) {
     String value = get(key);
@@ -151,7 +151,7 @@ public long getLong(String key, long defaultValue) {
 
   /**
    * Returns the double value to which the specified key is mapped,
-   * or defaultValue if there is no mapping for the key. The key match is case-insensitive
+   * or defaultValue if there is no mapping for the key. The key match is case-insensitive.
    */
   public double getDouble(String key, double defaultValue) {
     String value = get(key);

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=${options.get(NUM_PARTITIONS).orElse("default")}"
+    s"numPartitions=${Option(options.get(NUM_PARTITIONS)).getOrElse("default")}"
 }
 
 case class RateStreamMicroBatchInputPartition(