Permalink
Browse files

style fix

  • Loading branch information...
1 parent 0c0e409 commit af470d375f224a2d5e95d3b78ddf62b536c36554 @CodingCat CodingCat committed Mar 3, 2014
@@ -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()

0 comments on commit af470d3

Please sign in to comment.