Add comments about the fix

markhamstra · Jul 20, 2015 · b5546ce · b5546ce
1 parent 30a9ad0
commit b5546ce
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -170,6 +170,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
     // Make fake resource offers on all executors
     private def makeOffers() {
       launchTasks(scheduler.resourceOffers(executorDataMap
+        // Filter out executors under killing
         .filterKeys(!executorsPendingToRemove.contains(_))
         .map { case (id, executorData) =>
           new WorkerOffer(id, executorData.executorHost, executorData.freeCores)
@@ -183,6 +184,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
 
     // Make fake resource offers on just one executor
     private def makeOffers(executorId: String) {
+      // Filter out executors under killing
       if (!executorsPendingToRemove.contains(executorId)) {
         val executorData = executorDataMap(executorId)
         launchTasks(scheduler.resourceOffers(