Fix Scala Style Errors

apache · Jun 11, 2018 · 4c8acfa · 4c8acfa
1 parent d3f24b5
commit 4c8acfa
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/core/src/test/scala/org/apache/spark/scheduler/MapStatusSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/MapStatusSuite.scala
@@ -194,29 +194,30 @@ class MapStatusSuite extends SparkFunSuite {
       .setMaster("local")
       .setAppName("YSPARK-500")
     val sizes = Array.fill[Long](500)(150L)
-    //Test default value
+    // Test default value
     withSpark(new SparkContext(conf)) { sc =>
       val status = MapStatus(null, sizes)
       assert(status.isInstanceOf[CompressedMapStatus])
     }
-    //Test Non-positive values
+    // Test Non-positive values
     for (s <- -1 to 0) {
       assertThrows[IllegalArgumentException] {
         conf.set(config.SHUFFLE_MIN_NUM_PARTS_TO_HIGHLY_COMPRESS, s)
-        withSpark(new SparkContext(conf)){ sc => //
+        withSpark(new SparkContext(conf)) { sc =>
           val status = MapStatus(null, sizes)
         }
       }
     }
-    //Test positive values
-    for(s <- 1 to 3000){
+    // Test positive values
+    for(s <- 1 to 3000) {
       conf.set(config.SHUFFLE_MIN_NUM_PARTS_TO_HIGHLY_COMPRESS, s)
       withSpark(new SparkContext(conf)) { sc =>
         val status = MapStatus(null, sizes)
-        if(sizes.length > s)
+        if(sizes.length > s) {
           assert(status.isInstanceOf[HighlyCompressedMapStatus])
-        else
+        } else {
           assert(status.isInstanceOf[CompressedMapStatus])
+        }
       }
     }
   }