Author: acmurthy
Date: Thu Oct 25 11:16:58 2007
New Revision: 588300
URL: http://svn.apache.org/viewvc?rev=588300&view=rev
Log:
HADOOP-2098. Log start & completion of empty jobs to JobHistory, which also
ensures that we close the file-descriptor of the job's history log opened
during job-submission. Contributed by Amar Kamat.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=588300&r1=588299&r2=588300&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Oct 25 11:16:58 2007
@@ -45,6 +45,10 @@
job.xml in the JobTracker and while displaying it on the webui in
jobconf.jsp. (Amar Kamat via acmurthy)
+ HADOOP-2098. Log start & completion of empty jobs to JobHistory, which
+ also ensures that we close the file-descriptor of the job's history log
+ opened during job-submission. (Amar Kamat via acmurthy)
+
Branch 0.15 (unreleased changes)
INCOMPATIBLE CHANGES
Modified:
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java?rev=588300&r1=588299&r2=588300&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
(original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java
Thu Oct 25 11:16:58 2007
@@ -251,7 +251,10 @@
status.setReduceProgress(1.0f);
status.setRunState(JobStatus.SUCCEEDED);
tasksInited = true;
-
+ JobHistory.JobInfo.logStarted(profile.getJobId(),
+ System.currentTimeMillis(), 0, 0);
+ JobHistory.JobInfo.logFinished(profile.getJobId(),
+ System.currentTimeMillis(), 0, 0, 0, 0);
// Special case because the Job is not queued
JobEndNotifier.registerNotification(this.getJobConf(), this.getStatus());
