Skip to content

Commit bd4a5dd

Browse files
committed
Style fix
1 parent 0b8ca93 commit bd4a5dd

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,8 +55,9 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
5555
val maxRegisteredWaitingTimeMs =
5656
conf.getTimeAsMs("spark.scheduler.maxRegisteredResourcesWaitingTime", "30s")
5757
val createTime = System.currentTimeMillis()
58-
// If this CoarseGrainedSchedulerBackend is changed to support multiple threads, then this may need
59-
// to be changed so that we don't share the serializer instance across threads
58+
// If this CoarseGrainedSchedulerBackend is changed to support multiple threads,
59+
// then this may need to be changed so that we don't share the serializer
60+
// instance across threads
6061
private val ser = SparkEnv.get.closureSerializer.newInstance()
6162

6263
private val executorDataMap = new HashMap[String, ExecutorData]

0 commit comments

Comments
 (0)