Skip to content

Commit 062c182

Browse files
committed
fix small bug for code style
1 parent 0a428cf commit 062c182

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,8 +145,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
145145
val serializedTask = ser.serialize(task)
146146
if (serializedTask.limit >= akkaFrameSize - 1024) {
147147
var msg = "Serialized task %s:%d was %d bytes which " +
148-
"exceeds spark.akka.frameSize (%d bytes)." +
149-
"Consider using broadcast variables for large values"
148+
"exceeds spark.akka.frameSize (%d bytes). " +
149+
"Consider using broadcast variables for large values."
150150
msg = msg.format(task.taskId, task.index, serializedTask.limit, akkaFrameSize)
151151
scheduler.error(msg)
152152
// TODO: Need to throw an exception?

core/src/test/scala/org/apache/spark/scheduler/CoarseGrainedSchedulerBackendSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,13 @@ import org.apache.spark.SparkContext._
2323
import java.nio.ByteBuffer
2424

2525
import org.scalatest.{BeforeAndAfterAll, BeforeAndAfter, FunSuite}
26+
2627
class CoarseGrainedSchedulerBackendSuite extends FunSuite with
27-
BeforeAndAfter with BeforeAndAfterAll {
28+
BeforeAndAfter with BeforeAndAfterAll {
2829

2930
override def beforeAll {
3031
System.setProperty("spark.akka.frameSize", "1")
3132
System.setProperty("spark.default.parallelism", "1")
32-
3333
}
3434

3535
override def afterAll {

0 commit comments

Comments
 (0)