hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r1130460 - /hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
Date Thu, 02 Jun 2011 10:06:24 GMT
Author: acmurthy
Date: Thu Jun  2 10:06:24 2011
New Revision: 1130460

URL: http://svn.apache.org/viewvc?rev=1130460&view=rev
Log:
Improved logging for cluster resource tracking.

Modified:
    hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java

Modified: hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java?rev=1130460&r1=1130459&r2=1130460&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
(original)
+++ hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
Thu Jun  2 10:06:24 2011
@@ -585,12 +585,12 @@ implements ResourceScheduler, CapacitySc
   public synchronized void addNode(NodeInfo nodeManager) {
     Resources.addTo(clusterResource, nodeManager.getTotalCapability());
     ++numNodeManagers;
+    LOG.info("Added node " + nodeManager.getNodeAddress() + 
+        " clusterResource: " + clusterResource);
   }
 
   @Override
   public synchronized void removeNode(NodeInfo nodeInfo) {
-    LOG.info("Removing node " + nodeInfo.getNodeAddress());
-    
     Resources.subtractFrom(clusterResource, nodeInfo.getTotalCapability());
     --numNodeManagers;
 
@@ -605,6 +605,9 @@ implements ResourceScheduler, CapacitySc
       Resource released = nodeInfo.getReservedResource();
       queue.completedContainer(clusterResource, null, released, reservedApplication);
     }
+    
+    LOG.info("Removed node " + nodeInfo.getNodeAddress() + 
+        " clusterResource: " + clusterResource);
   }
   
   public synchronized boolean releaseContainer(ApplicationId applicationId, 



Mime
View raw message