You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by ac...@apache.org on 2009/07/30 01:36:42 UTC
svn commit: r799126 - in /hadoop/mapreduce/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/JobInProgress.java
Author: acmurthy
Date: Wed Jul 29 23:36:42 2009
New Revision: 799126
URL: http://svn.apache.org/viewvc?rev=799126&view=rev
Log:
MAPREDUCE-809. Fix job-summary logs to correctly record status of FAILED and KILLED jobs.
Modified:
hadoop/mapreduce/trunk/CHANGES.txt
hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=799126&r1=799125&r2=799126&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Wed Jul 29 23:36:42 2009
@@ -283,3 +283,7 @@
MAPREDUCE-383. Fix a bug in Pipes combiner due to bytes count not
getting reset after the spill. (Christian Kunz via sharad)
+
+ MAPREDUCE-809. Fix job-summary logs to correctly record status of FAILED
+ and KILLED jobs.
+
Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java?rev=799126&r1=799125&r2=799126&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java Wed Jul 29 23:36:42 2009
@@ -2632,14 +2632,16 @@
private synchronized void terminateJob(int jobTerminationState) {
if ((status.getRunState() == JobStatus.RUNNING) ||
(status.getRunState() == JobStatus.PREP)) {
- // Log the job summary
- JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
-
if (jobTerminationState == JobStatus.FAILED) {
this.status = new JobStatus(status.getJobID(),
1.0f, 1.0f, 1.0f, JobStatus.FAILED,
status.getJobPriority());
this.finishTime = JobTracker.getClock().getTime();
+
+ // Log the job summary
+ JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
+
+ // Log to job-history
JobHistory.JobInfo.logFailed(this.status.getJobID(), finishTime,
this.finishedMapTasks,
this.finishedReduceTasks);
@@ -2648,6 +2650,11 @@
1.0f, 1.0f, 1.0f, JobStatus.KILLED,
status.getJobPriority());
this.finishTime = JobTracker.getClock().getTime();
+
+ // Log the job summary
+ JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
+
+ // Log to job-history
JobHistory.JobInfo.logKilled(this.status.getJobID(), finishTime,
this.finishedMapTasks,
this.finishedReduceTasks);