hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject svn commit: r706154 - in /hadoop/core/trunk: CHANGES.txt src/mapred/org/apache/hadoop/mapred/JobInProgress.java
Date Mon, 20 Oct 2008 08:56:33 GMT
Author: ddas
Date: Mon Oct 20 01:56:32 2008
New Revision: 706154

URL: http://svn.apache.org/viewvc?rev=706154&view=rev
Log:
HADOOP-4457. Fixes an input split logging problem introduced by HADOOP-3245. Contributed by
Amareshwari Sriramadasu.

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobInProgress.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=706154&r1=706153&r2=706154&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Mon Oct 20 01:56:32 2008
@@ -964,6 +964,9 @@
     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

Modified: hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobInProgress.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobInProgress.java?rev=706154&r1=706153&r2=706154&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobInProgress.java (original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobInProgress.java Mon Oct 20 01:56:32
2008
@@ -1091,6 +1091,7 @@
                                         boolean isScheduled) {
     // keeping the earlier ordering intact
     String name;
+    String splits = "";
     Enum counter = null;
     if (tip.isSetupTask()) {
       launchedSetup = true;
@@ -1102,6 +1103,7 @@
       ++runningMapTasks;
       name = Values.MAP.name();
       counter = Counter.TOTAL_LAUNCHED_MAPS;
+      splits = tip.getSplitNodes();
       if (tip.getActiveTasks().size() > 1)
         speculativeMapTasks++;
     } else {
@@ -1115,7 +1117,7 @@
     // 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);



Mime
View raw message