From eae69ce5a5d6f7ccd3d87d4f9379cae8d081518c Mon Sep 17 00:00:00 2001 From: "yi.wu" Date: Fri, 27 Dec 2019 14:04:00 +0800 Subject: [PATCH] revert last change which fails test --- .../spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 1 - 1 file changed, 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 index dc828968b4ed6..9add1e05805eb 100644 --- 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 = {