This is an automated email from the ASF dual-hosted git repository.

sunilg pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 71c49fa  YARN-9099. GpuResourceAllocator#getReleasingGpus calculates 
number of GPUs in a wrong way. Contributed by Szilard Nemeth.
71c49fa is described below

commit 71c49fa60faad2504b0411979a6e46e595b97a85
Author: Sunil G <sun...@apache.org>
AuthorDate: Thu Jan 31 09:25:29 2019 +0530

    YARN-9099. GpuResourceAllocator#getReleasingGpus calculates number of GPUs 
in a wrong way. Contributed by Szilard Nemeth.
---
 .../containermanager/linux/resources/gpu/GpuResourceAllocator.java   | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/gpu/GpuResourceAllocator.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/gpu/GpuResourceAllocator.java
index 28584b5..2496ac8 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/gpu/GpuResourceAllocator.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/gpu/GpuResourceAllocator.java
@@ -258,10 +258,7 @@ public class GpuResourceAllocator {
 
   private synchronized long getReleasingGpus() {
     long releasingGpus = 0;
-    Iterator<Map.Entry<GpuDevice, ContainerId>> iter = usedDevices.entrySet()
-        .iterator();
-    while (iter.hasNext()) {
-      ContainerId containerId = iter.next().getValue();
+    for (ContainerId containerId : ImmutableSet.copyOf(usedDevices.values())) {
       Container container;
       if ((container = nmContext.getContainers().get(containerId)) != null) {
         if (container.isContainerInFinalStates()) {


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

Reply via email to