diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java index 15d3289..6551d07 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java @@ -604,7 +604,7 @@ private synchronized void activateApplications() { for (Iterator i=pendingApplications.iterator(); i.hasNext(); ) { FiCaSchedulerApp application = i.next(); - + ApplicationId applicationId = application.getApplicationId(); // Check am resource limit Resource amIfStarted = Resources.add(application.getAMResource(), queueUsage.getAMUsed()); @@ -624,7 +624,9 @@ private synchronized void activateApplications() { " single application in queue, it is likely set too low." + " skipping enforcement to allow at least one application to start"); } else { - LOG.info("not starting application as amIfStarted exceeds amLimit"); + LOG.info("Not activating " + applicationId + + ". If application activated usedAMResource " + amIfStarted + + " will exceed amLimit " + amLimit); continue; } } @@ -645,8 +647,9 @@ private synchronized void activateApplications() { " single application in queue for user, it is likely set too low." + " skipping enforcement to allow at least one application to start"); } else { - LOG.info("not starting application as amIfStarted exceeds " + - "userAmLimit"); + LOG.info("Not activating " + applicationId + " for user " + user + + ". If application activated usedUserAMResource " + + userAmIfStarted + " will exceed userAmLimit " + userAMLimit); continue; } } @@ -657,9 +660,8 @@ private synchronized void activateApplications() { metrics.incAMUsed(application.getUser(), application.getAMResource()); metrics.setAMResouceLimitForUser(application.getUser(), userAMLimit); i.remove(); - LOG.info("Application " + application.getApplicationId() + - " from user: " + application.getUser() + - " activated in queue: " + getQueueName()); + LOG.info("Application " + applicationId + " from user: " + + application.getUser() + " activated in queue: " + getQueueName()); } }