ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Minor fix for the previous commit.

Browse source
This commit is contained in:
Reynold Xin 2014-09-27 22:18:02 -07:00
parent 9966d1a8aa
commit 66e1c40c67
2 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -142,9 +142,9 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
// Make fake resource offers on all executors
def makeOffers() {
launchTasks(scheduler.resourceOffers(
executorDataMap.map {case (id, executorData) =>
new WorkerOffer(id, executorData.executorHost, executorData.freeCores)}.toSeq))
launchTasks(scheduler.resourceOffers(executorDataMap.map { case (id, executorData) =>
new WorkerOffer(id, executorData.executorHost, executorData.freeCores)
}.toSeq))
}
// Make fake resource offers on just one executor

5
core/src/main/scala/org/apache/spark/scheduler/cluster/ExecutorData.scala
View file

@ -20,10 +20,9 @@ package org.apache.spark.scheduler.cluster
import akka.actor.{Address, ActorRef}
/**
* Grouping of data that is accessed by a CourseGrainedScheduler. This class
* is stored in a Map keyed by an executorID
* Grouping of data for an executor used by CoarseGrainedSchedulerBackend.
*
* @param executorActor The actorRef representing this executor
* @param executorActor The ActorRef representing this executor
* @param executorAddress The network address of this executor
* @param executorHost The hostname that this executor is running on
* @param freeCores The current number of cores available for work on the executor