Author: acmurthy
Date: Wed Aug 10 23:32:04 2011
New Revision: 1156402
URL: http://svn.apache.org/viewvc?rev=1156402&view=rev
Log:
MAPREDUCE-2706. Log job submission failures. Contributed by Jeffrey Naisbitt.
Modified:
hadoop/common/branches/MR-279/mapreduce/CHANGES.txt
hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Modified: hadoop/common/branches/MR-279/mapreduce/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/MR-279/mapreduce/CHANGES.txt?rev=1156402&r1=1156401&r2=1156402&view=diff
==============================================================================
--- hadoop/common/branches/MR-279/mapreduce/CHANGES.txt (original)
+++ hadoop/common/branches/MR-279/mapreduce/CHANGES.txt Wed Aug 10 23:32:04 2011
@@ -4,6 +4,9 @@ Trunk (unreleased changes)
MAPREDUCE-279
+ MAPREDUCE-2706. Log job submission failures. (Jeffrey Naisbitt via
+ acmurthy)
+
MAPREDUCE-2782. Unit tests for CapacityScheduler. (acmurthy)
Fix for running ant targets to use the right set of common/test jars
Modified: hadoop/common/branches/MR-279/mapreduce/yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.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/LeafQueue.java?rev=1156402&r1=1156401&r2=1156402&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/LeafQueue.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/LeafQueue.java
Wed Aug 10 23:32:04 2011
@@ -414,27 +414,33 @@ public class LeafQueue implements Queue
// Check if the queue is accepting jobs
if (state != QueueState.RUNNING) {
- throw new AccessControlException("Queue " + getQueuePath() +
- " is STOPPED. Cannot accept submission of application: " +
- application.getApplicationId());
+ String msg = "Queue " + getQueuePath() +
+ " is STOPPED. Cannot accept submission of application: " +
+ application.getApplicationId();
+ LOG.info(msg);
+ throw new AccessControlException(msg);
}
// Check submission limits for queues
if (getNumApplications() >= maxApplications) {
- throw new AccessControlException("Queue " + getQueuePath() +
- " already has " + getNumApplications() + " applications," +
- " cannot accept submission of application: " +
- application.getApplicationId());
+ String msg = "Queue " + getQueuePath() +
+ " already has " + getNumApplications() + " applications," +
+ " cannot accept submission of application: " +
+ application.getApplicationId();
+ LOG.info(msg);
+ throw new AccessControlException(msg);
}
// Check submission limits for the user on this queue
user = getUser(userName);
if (user.getApplications() >= maxApplicationsPerUser) {
- throw new AccessControlException("Queue " + getQueuePath() +
- " already has " + user.getApplications() +
- " applications from user " + userName +
- " cannot accept submission of application: " +
- application.getApplicationId());
+ String msg = "Queue " + getQueuePath() +
+ " already has " + user.getApplications() +
+ " applications from user " + userName +
+ " cannot accept submission of application: " +
+ application.getApplicationId();
+ LOG.info(msg);
+ throw new AccessControlException(msg);
}
// Add the application to our data-structures
|