Browse Source

CapacityScheduler works on single node!

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/MR-279@1153443 13f79535-47bb-0310-9956-ffa450edef68
Vinod Kumar Vavilapalli 14 years ago
parent
commit
25759e3383

+ 2 - 1
mapreduce/yarn/yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java

@@ -103,7 +103,8 @@ public class AsyncDispatcher extends AbstractService implements Dispatcher {
   @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();
 

+ 1 - 2
mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java

@@ -536,8 +536,7 @@ implements ResourceScheduler, CapacitySchedulerContext {
   }
 
   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.