hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r1156402 - in /hadoop/common/branches/MR-279/mapreduce: CHANGES.txt yarn/yarn-server/yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java
Date Wed, 10 Aug 2011 23:32:05 GMT
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



Mime
View raw message