From af470d375f224a2d5e95d3b78ddf62b536c36554 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Mon, 3 Mar 2014 09:52:45 -0500 Subject: [PATCH] style fix --- .../scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 index 82dfe06a5f644..9ca04f57f3616 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala @@ -73,7 +73,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A logInfo("Registered executor: " + sender + " with ID " + executorId) sender ! RegisteredExecutor(sparkProperties) executorActor(executorId) = sender - workerOffers += (executorId -> new WorkerOffer(executorId, Utils.parseHostPort(hostPort)._1, cores)) + workerOffers += (executorId -> + new WorkerOffer(executorId, Utils.parseHostPort(hostPort)._1, cores)) addressToExecutorId(sender.path.address) = executorId totalCoreCount.addAndGet(cores) makeOffers()