Author: mahadev
Date: Thu Apr 28 23:29:16 2011
New Revision: 1097657
URL: http://svn.apache.org/viewvc?rev=1097657&view=rev
Log:
Clear application notification if sent once to NodeManager (mahadev)
Modified:
hadoop/mapreduce/branches/MR-279/CHANGES.txt
hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/NodeManagerImpl.java
Modified: hadoop/mapreduce/branches/MR-279/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/CHANGES.txt?rev=1097657&r1=1097656&r2=1097657&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/CHANGES.txt (original)
+++ hadoop/mapreduce/branches/MR-279/CHANGES.txt Thu Apr 28 23:29:16 2011
@@ -58,6 +58,8 @@ Trunk (unreleased changes)
Implement restart for resource manager phase 1 - Helper classes to store and restore
the data structures. (mahadev)
MAPREDUCE-2433. YARNApplicationConstants hard code app master jar version (Luke Lu via
mahadev)
+
+ Clear application notification if sent once to NodeManager (mahadev)
INCOMPATIBLE CHANGES
Modified: hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/NodeManagerImpl.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/NodeManagerImpl.java?rev=1097657&r1=1097656&r2=1097657&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/NodeManagerImpl.java
(original)
+++ hadoop/mapreduce/branches/MR-279/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/NodeManagerImpl.java
Thu Apr 28 23:29:16 2011
@@ -190,6 +190,7 @@ public class NodeManagerImpl implements
/* clear out containers to clean */
containersToClean.clear();
lastfinishedApplications.addAll(finishedApplications);
+ finishedApplications.clear();
return new NodeResponse(lastfinishedApplications, completedContainers,
containersToCleanUp);
}
|