hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vino...@apache.org
Subject svn commit: r1153443 - in /hadoop/common/branches/MR-279/mapreduce/yarn: yarn-common/src/main/java/org/apache/hadoop/yarn/event/ yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/
Date Wed, 03 Aug 2011 11:45:25 GMT
Author: vinodkv
Date: Wed Aug  3 11:45:25 2011
New Revision: 1153443

URL: http://svn.apache.org/viewvc?rev=1153443&view=rev
Log:
CapacityScheduler works on single node!

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

Modified: hadoop/common/branches/MR-279/mapreduce/yarn/yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/MR-279/mapreduce/yarn/yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java?rev=1153443&r1=1153442&r2=1153443&view=diff
==============================================================================
--- hadoop/common/branches/MR-279/mapreduce/yarn/yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
(original)
+++ hadoop/common/branches/MR-279/mapreduce/yarn/yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
Wed Aug  3 11:45:25 2011
@@ -103,7 +103,8 @@ public class AsyncDispatcher extends Abs
   @SuppressWarnings("unchecked")
   protected void dispatch(Event event) {
     //all events go thru this loop
-    LOG.info("Dispatching the event " + event.toString());
+    LOG.info("Dispatching the event " + event.getClass().getName() + "."
+        + event.toString());
 
     Class<? extends Enum> type = event.getType().getDeclaringClass();
 

Modified: hadoop/common/branches/MR-279/mapreduce/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/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java?rev=1153443&r1=1153442&r2=1153443&view=diff
==============================================================================
--- hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
(original)
+++ hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
Wed Aug  3 11:45:25 2011
@@ -536,8 +536,7 @@ implements ResourceScheduler, CapacitySc
   }
 
   private void processSingleCompletedContainer(Container container) {
-    CSApp application = getApplication(this.rmContext.getRMContainers().get(
-        container.getId()).getApplicationAttemptId());
+    CSApp application = getApplication(container.getId().getAppAttemptId());
 
     // this is possible, since an application can be removed from scheduler 
     // but the nodemanger is just updating about a completed container.



Mime
View raw message