@@ -169,12 +169,12 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
169169
170170 // Make fake resource offers on all executors
171171 private def makeOffers () {
172- launchTasks(scheduler.resourceOffers(executorDataMap
173- // Filter out executors under killing
174- .filterKeys( ! executorsPendingToRemove.contains(_))
175- .map { case (id, executorData) =>
176- new WorkerOffer (id, executorData.executorHost, executorData.freeCores)
177- }.toSeq ))
172+ // Filter out executors under killing
173+ val activeExecutors = executorDataMap.filterKeys( ! executorsPendingToRemove.contains(_))
174+ val workOffers = activeExecutors.map { case (id, executorData) =>
175+ new WorkerOffer (id, executorData.executorHost, executorData.freeCores)
176+ }.toSeq
177+ launchTasks(scheduler.resourceOffers(workOffers ))
178178 }
179179
180180 override def onDisconnected (remoteAddress : RpcAddress ): Unit = {
@@ -187,8 +187,8 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
187187 // Filter out executors under killing
188188 if (! executorsPendingToRemove.contains(executorId)) {
189189 val executorData = executorDataMap(executorId)
190- launchTasks(scheduler.resourceOffers(
191- Seq ( new WorkerOffer (executorId, executorData.executorHost, executorData.freeCores)) ))
190+ val workOffers = Seq ( new WorkerOffer (executorId, executorData.executorHost, executorData.freeCores))
191+ launchTasks(scheduler.resourceOffers(workOffers ))
192192 }
193193 }
194194
0 commit comments