revert last change which fails test

apache · Dec 27, 2019 · eae69ce · eae69ce
1 parent 3368a3e
commit eae69ce
Showing 1 changed file with 0 additions and 1 deletion.
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
@@ -506,7 +506,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
     executors.foreach { eid =>
       removeExecutor(eid, SlaveLost("Stale executor after cluster manager re-registered."))
     }
-    synchronized { executorsPendingToRemove.clear() }
   }
 
   override def reviveOffers(): Unit = {