Skip to content

Commit

Permalink
style fix
Browse files Browse the repository at this point in the history
  • Loading branch information
CodingCat committed Mar 3, 2014
1 parent 0c0e409 commit af470d3
Showing 1 changed file with 2 additions and 1 deletion.
Expand Up @@ -73,7 +73,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
logInfo("Registered executor: " + sender + " with ID " + executorId) logInfo("Registered executor: " + sender + " with ID " + executorId)
sender ! RegisteredExecutor(sparkProperties) sender ! RegisteredExecutor(sparkProperties)
executorActor(executorId) = sender 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 addressToExecutorId(sender.path.address) = executorId
totalCoreCount.addAndGet(cores) totalCoreCount.addAndGet(cores)
makeOffers() makeOffers()
Expand Down

0 comments on commit af470d3

Please sign in to comment.