comment fix

apache · Oct 21, 2016 · 7bf3bf8 · 7bf3bf8
1 parent 7d86054
commit 7bf3bf8
Showing 1 changed file with 1 addition and 5 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
@@ -145,9 +145,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
             // Ignoring the task kill since the executor is not registered.
             logWarning(s"Attempted to kill task $taskId for unknown executor $executorId.")
         }
-
-      case RemoveExecutor(executorId, reason) =>
-        removeExecutor(executorId, reason)
     }
 
     override def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit] = {
@@ -399,8 +396,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
     // Remove all the lingering executors that should be removed but not yet. The reason might be
     // because (1) disconnected event is not yet received; (2) executors die silently.
     executors.foreach { eid =>
-      driverEndpoint.send(
-        RemoveExecutor(eid, SlaveLost("Stale executor after cluster manager re-registered.")))
+      removeExecutor(eid, SlaveLost("Stale executor after cluster manager re-registered."))
     }
   }