From 59de77b5f523340d50836f072b38afee9bf579c3 Mon Sep 17 00:00:00 2001
From: hushan <hushan@xiaomi.com>
Date: Tue, 23 Aug 2016 11:02:53 +0800
Subject: [PATCH] Fix hang

---
 .../scala/org/apache/spark/ExecutorAllocationManager.scala | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala b/core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala
index 932ba16812bbb..a4b70027c458b 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) {