Ver Fonte

MAPREDUCE-6071. JobImpl#makeUberDecision doesn't log that Uber mode is disabled because of too much CPUs. Contributed by Tsuyoshi OZAWA
(cherry picked from commit 45efc966ee1a1bda0271464dcee2564862d53b1f)

Jason Lowe há 11 anos atrás
pai
commit
0b3f918b3b

+ 3 - 0
hadoop-mapreduce-project/CHANGES.txt

@@ -121,6 +121,9 @@ Release 2.6.0 - UNRELEASED
     MAPREDUCE-6063. Correct spill size calculation for spills wrapping the
     MAPREDUCE-6063. Correct spill size calculation for spills wrapping the
     circular buffer. (zhihai xu via cdouglas)
     circular buffer. (zhihai xu via cdouglas)
 
 
+    MAPREDUCE-6071. JobImpl#makeUberDecision doesn't log that Uber mode is
+    disabled because of too much CPUs (Tsuyoshi OZAWA via jlowe)
+
 Release 2.5.1 - UNRELEASED
 Release 2.5.1 - UNRELEASED
 
 
   INCOMPATIBLE CHANGES
   INCOMPATIBLE CHANGES

+ 2 - 0
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/JobImpl.java

@@ -1285,6 +1285,8 @@ public class JobImpl implements org.apache.hadoop.mapreduce.v2.app.job.Job,
         msg.append(" too many reduces;");
         msg.append(" too many reduces;");
       if (!smallInput)
       if (!smallInput)
         msg.append(" too much input;");
         msg.append(" too much input;");
+      if (!smallCpu)
+        msg.append(" too much CPU;");
       if (!smallMemory)
       if (!smallMemory)
         msg.append(" too much RAM;");
         msg.append(" too much RAM;");
       if (!notChainJob)
       if (!notChainJob)