diff --git a/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala b/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala index 932ba16812bb..a4b70027c458 100644 --- a/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala +++ b/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala @@ -364,13 +364,6 @@ private[spark] class ExecutorAllocationManager( val delta = numExecutorsTarget - oldNumExecutorsTarget - // If our target has not changed, do not send a message - // to the cluster manager and reset our exponential growth - if (delta == 0) { - numExecutorsToAdd = 1 - return 0 - } - val addRequestAcknowledged = testing || client.requestTotalExecutors(numExecutorsTarget, localityAwareTasks, hostToLocalTaskCount) if (addRequestAcknowledged) {