fix small bug for code style

markhamstra · May 14, 2014 · 062c182 · 062c182
1 parent 0a428cf
commit 062c182
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
@@ -145,8 +145,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
         val serializedTask = ser.serialize(task)
         if (serializedTask.limit >= akkaFrameSize - 1024) {
           var msg = "Serialized task %s:%d was %d bytes which " +
-            "exceeds spark.akka.frameSize (%d bytes)." +
-            "Consider using broadcast variables for large values"
+            "exceeds spark.akka.frameSize (%d bytes). " +
+            "Consider using broadcast variables for large values."
           msg = msg.format(task.taskId, task.index, serializedTask.limit, akkaFrameSize)
           scheduler.error(msg)
           // TODO: Need to throw an exception?

diff --git a/core/src/test/scala/org/apache/spark/scheduler/CoarseGrainedSchedulerBackendSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/CoarseGrainedSchedulerBackendSuite.scala
@@ -23,13 +23,13 @@ import org.apache.spark.SparkContext._
 import java.nio.ByteBuffer
 
 import org.scalatest.{BeforeAndAfterAll, BeforeAndAfter, FunSuite}
+
 class CoarseGrainedSchedulerBackendSuite extends FunSuite with
-BeforeAndAfter with BeforeAndAfterAll {
+  BeforeAndAfter with BeforeAndAfterAll {
 
   override def beforeAll {
     System.setProperty("spark.akka.frameSize", "1")
     System.setProperty("spark.default.parallelism", "1")
-
   }
 
   override def afterAll {