From 4c8acfa5899ccbdafeb630f38ce44b23332b80f2 Mon Sep 17 00:00:00 2001
From: Hieu Huynh <“Hieu.huynh@oath.com”>
Date: Mon, 11 Jun 2018 16:16:58 -0500
Subject: [PATCH] Fix Scala Style Errors

---
 .../apache/spark/scheduler/MapStatusSuite.scala   | 15 ++++++++-------
 1 file changed, 8 insertions(+), 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
index f09ca806d3a43..b7f8a57d6a644 100644
--- 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])
+        }
       }
     }
   }