diff options
| author | Xutingjun <1039320815@qq.com> | 2015-02-02 12:37:51 -0800 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-02-02 12:37:51 -0800 |
| commit | 62a93a1698e8d0a667eb1718ba75dcfc86eabaaf (patch) | |
| tree | 4d406bcb8db4df4a00a440a98ffe26be5ac851a9 /yarn | |
| parent | 3f941b68a2336aa7876aeda99865e7c19b53bc5c (diff) | |
| download | spark-62a93a1698e8d0a667eb1718ba75dcfc86eabaaf.tar.gz spark-62a93a1698e8d0a667eb1718ba75dcfc86eabaaf.tar.bz2 spark-62a93a1698e8d0a667eb1718ba75dcfc86eabaaf.zip | |
[SPARK-5530] Add executor container to executorIdToContainer
when call killExecutor method, it will only go to the else branch, because the variable executorIdToContainer never be put any value.
Author: Xutingjun <1039320815@qq.com>
Closes #4309 from XuTingjun/dynamicAllocator and squashes the following commits:
c823418 [Xutingjun] fix bugwq
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala index 3849586c61..040406c150 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala @@ -300,6 +300,7 @@ private[yarn] class YarnAllocator( assert(container.getResource.getMemory >= resource.getMemory) logInfo("Launching container %s for on host %s".format(containerId, executorHostname)) + executorIdToContainer(executorId) = container val containerSet = allocatedHostToContainersMap.getOrElseUpdate(executorHostname, new HashSet[ContainerId]) |