hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r1129875 - /hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/resourcetracker/RMResourceTrackerImpl.java
Date Tue, 31 May 2011 19:37:16 GMT
Author: acmurthy
Date: Tue May 31 19:37:16 2011
New Revision: 1129875

URL: http://svn.apache.org/viewvc?rev=1129875&view=rev
Log:
Missed a minor change in 'lost' NM patch.

Modified:
    hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/resourcetracker/RMResourceTrackerImpl.java

Modified: hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/resourcetracker/RMResourceTrackerImpl.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/resourcetracker/RMResourceTrackerImpl.java?rev=1129875&r1=1129874&r2=1129875&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/resourcetracker/RMResourceTrackerImpl.java
(original)
+++ hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/resourcetracker/RMResourceTrackerImpl.java
Tue May 31 19:37:16 2011
@@ -503,11 +503,16 @@ NodeTracker, ClusterTracker {
   public void finishedApplication(ApplicationId applicationId,
       List<NodeInfo> nodesToNotify) {
     for (NodeInfo info: nodesToNotify) {
-      NodeManager node;
+      NodeManager node = null;
       synchronized(nodeManagers) {
-        node = nodeManagers.get(info.getNodeID()).getNodeManager();
+        NodeInfoTracker nodeInfo = nodeManagers.get(info.getNodeID());
+        if (nodeInfo != null) {
+          node = nodeInfo.getNodeManager();
+        }
+      }
+      if (node != null) {
+        node.finishedApplication(applicationId);
       }
-      node.finishedApplication(applicationId);
     } 
   }
 



Mime
View raw message