You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by dd...@apache.org on 2009/05/08 12:20:13 UTC
svn commit: r772920 - in /hadoop/core/trunk: CHANGES.txt
src/mapred/org/apache/hadoop/mapred/JobInProgress.java
Author: ddas
Date: Fri May 8 10:20:13 2009
New Revision: 772920
URL: http://svn.apache.org/viewvc?rev=772920&view=rev
Log:
HADOOP-5636. Prevents a job from going to RUNNING state after it has been KILLED (this used to happen when the SetupTask would come back with a success after the job has been killed). Contributed by Amar Kamat.
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=772920&r1=772919&r2=772920&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Fri May 8 10:20:13 2009
@@ -590,6 +590,10 @@
path value that is returned for the case where the file we want to write
is of an unknown size. (Vinod Kumar Vavilapalli via ddas)
+ HADOOP-5636. Prevents a job from going to RUNNING state after it has been
+ KILLED (this used to happen when the SetupTask would come back with a
+ success after the job has been killed). (Amar Kamat via ddas)
+
Release 0.20.0 - 2009-04-15
INCOMPATIBLE CHANGES
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=772920&r1=772919&r2=772920&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 Fri May 8 10:20:13 2009
@@ -2039,8 +2039,11 @@
killSetupTip(!tip.isMapTask());
// Job can start running now.
this.status.setSetupProgress(1.0f);
- this.status.setRunState(JobStatus.RUNNING);
- JobHistory.JobInfo.logStarted(profile.getJobID());
+ // move the job to running state if the job is in prep state
+ if (this.status.getRunState() == JobStatus.PREP) {
+ this.status.setRunState(JobStatus.RUNNING);
+ JobHistory.JobInfo.logStarted(profile.getJobID());
+ }
} else if (tip.isJobCleanupTask()) {
// cleanup task has finished. Kill the extra cleanup tip
if (tip.isMapTask()) {