Просмотр исходного кода

YARN-6188. Fix OOM issue with decommissioningNodesWatcher in the case of clusters with
large number of nodes (Contributed by Ajay Jadhav via Daniel Templeton)

Daniel Templeton 8 лет назад
Родитель
Сommit
9a92837786

+ 2 - 2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java

@@ -385,9 +385,9 @@ public class DecommissioningNodesWatcher {
     if (!LOG.isDebugEnabled() || decomNodes.size() == 0) {
       return;
     }
-    StringBuilder sb = new StringBuilder();
     long now = mclock.getTime();
     for (DecommissioningNodeContext d : decomNodes.values()) {
+      StringBuilder sb = new StringBuilder();
       DecommissioningNodeStatus s = checkDecommissioningStatus(d.nodeId);
       sb.append(String.format(
           "%n  %-34s %4ds fresh:%3ds containers:%2d %14s",
@@ -413,8 +413,8 @@ public class DecommissioningNodesWatcher {
               (mclock.getTime() - rmApp.getStartTime()) / 1000));
         }
       }
+      LOG.debug("Decommissioning node: " + sb.toString());
     }
-    LOG.info("Decommissioning Nodes: " + sb.toString());
   }
 
   // Read possible new DECOMMISSIONING_TIMEOUT_KEY from yarn-site.xml.