Skip to content

Commit

Permalink
scala style fix
Browse files Browse the repository at this point in the history
  • Loading branch information
GraceH committed Jul 21, 2015
1 parent 6e2ed96 commit ecc1da6
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -187,7 +187,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
// Filter out executors under killing
if (!executorsPendingToRemove.contains(executorId)) {
val executorData = executorDataMap(executorId)
val workOffers = Seq(new WorkerOffer(executorId, executorData.executorHost, executorData.freeCores))
val workOffers = Seq(
new WorkerOffer(executorId, executorData.executorHost, executorData.freeCores))
launchTasks(scheduler.resourceOffers(workOffers))
}
}
Expand Down

0 comments on commit ecc1da6

Please sign in to comment.