Explorar el Código

HADOOP-4457. Fixes an input split logging problem introduced by HADOOP-3245. Contributed by Amareshwari Sriramadasu.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@706154 13f79535-47bb-0310-9956-ffa450edef68
Devaraj Das hace 16 años
padre
commit
e04274bcea
Se han modificado 2 ficheros con 6 adiciones y 1 borrados
  1. 3 0
      CHANGES.txt
  2. 3 1
      src/mapred/org/apache/hadoop/mapred/JobInProgress.java

+ 3 - 0
CHANGES.txt

@@ -964,6 +964,9 @@ Release 0.19.0 - Unreleased
     HADOOP-4399. Make fuse-dfs multi-thread access safe.
     (Pete Wyckoff via dhruba)
 
+    HADOOP-4457. Fixes an input split logging problem introduced by
+    HADOOP-3245. (Amareshwari Sriramadasu via ddas)
+
 Release 0.18.2 - Unreleased
 
   BUG FIXES

+ 3 - 1
src/mapred/org/apache/hadoop/mapred/JobInProgress.java

@@ -1091,6 +1091,7 @@ class JobInProgress {
                                         boolean isScheduled) {
     // keeping the earlier ordering intact
     String name;
+    String splits = "";
     Enum counter = null;
     if (tip.isSetupTask()) {
       launchedSetup = true;
@@ -1102,6 +1103,7 @@ class JobInProgress {
       ++runningMapTasks;
       name = Values.MAP.name();
       counter = Counter.TOTAL_LAUNCHED_MAPS;
+      splits = tip.getSplitNodes();
       if (tip.getActiveTasks().size() > 1)
         speculativeMapTasks++;
     } else {
@@ -1115,7 +1117,7 @@ class JobInProgress {
     // restart has already their logs in place.
     if (tip.isFirstAttempt(id)) {
       JobHistory.Task.logStarted(tip.getTIPId(), name,
-                                 tip.getExecStartTime(), "");
+                                 tip.getExecStartTime(), splits);
     }
     if (!tip.isSetupTask() && !tip.isCleanupTask()) {
       jobCounters.incrCounter(counter, 1);