Author: acmurthy
Date: Thu Oct 11 12:50:23 2007
New Revision: 583937
URL: http://svn.apache.org/viewvc?rev=583937&view=rev
Log:
HADOOP-2022. Ensure that status information for successful tasks is correctly
recorded at the JobTracker, so that, for example, one may view correct
information via taskdetails.jsp. This bug was introduced by HADOOP-1874.
Contributed by Amar Kamat.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=583937&r1=583936&r2=583937&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Oct 11 12:50:23 2007
@@ -266,6 +266,11 @@
HADOOP-2026. Namenode prints out one log line for "Number of transactions"
at most once every minute. (Dhruba Borthakur)
+ HADOOP-2022. Ensure that status information for successful tasks is
correctly
+ recorded at the JobTracker, so that, for example, one may view correct
+ information via taskdetails.jsp. This bug was introduced by HADOOP-1874.
+ (Amar Kamat via acmurthy)
+
IMPROVEMENTS
HADOOP-1908. Restructure data node code so that block sending and
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=583937&r1=583936&r2=583937&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java
(original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Thu
Oct 11 12:50:23 2007
@@ -1962,15 +1962,9 @@
//saving the output,the JT would have called updateTaskStatus
//and we don't need to call it again
if (status.getRunState() == TaskStatus.State.COMMIT_PENDING){
- newStatus = TaskStatus.createTaskStatus(
- tip.isMapTask(),
- taskid,
- state == TaskStatus.State.SUCCEEDED ? 1.0f : 0.0f,
- state,
- status.getDiagnosticInfo(),
- status.getStateString(),
- status.getTaskTracker(), status.getPhase(),
- status.getCounters());
+ newStatus = (TaskStatus)status.clone();
+ newStatus.setRunState(state);
+ newStatus.setProgress((state ==
TaskStatus.State.SUCCEEDED) ? 1.0f : 0.0f);
}
}
if (newStatus != null) {
