Skip to content

Commit 59de77b

Browse files
committed
Fix hang
1 parent 2cdd92a commit 59de77b

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -364,13 +364,6 @@ private[spark] class ExecutorAllocationManager(
364364

365365
val delta = numExecutorsTarget - oldNumExecutorsTarget
366366

367-
// If our target has not changed, do not send a message
368-
// to the cluster manager and reset our exponential growth
369-
if (delta == 0) {
370-
numExecutorsToAdd = 1
371-
return 0
372-
}
373-
374367
val addRequestAcknowledged = testing ||
375368
client.requestTotalExecutors(numExecutorsTarget, localityAwareTasks, hostToLocalTaskCount)
376369
if (addRequestAcknowledged) {

0 commit comments

Comments
 (0)