revert last change which fails test

Ngone51 · Ngone51 · commit eae69ce5a5d6 · 2019-12-27T14:04:00.000+08:00
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 = {

Original file line number	Diff line number	Diff line change
`@@ -506,7 +506,6 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp`
`506`	`506`	`executors.foreach { eid =>`
`507`	`507`	`removeExecutor(eid, SlaveLost("Stale executor after cluster manager re-registered."))`
`508`	`508`	`}`
`509`		`- synchronized { executorsPendingToRemove.clear() }`
`510`	`509`	`}`
`511`	`510`
`512`	`511`	`override def reviveOffers(): Unit = {`