hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r588300 - in /lucene/hadoop/trunk: CHANGES.txt src/java/org/apache/hadoop/mapred/JobInProgress.java
Date Thu, 25 Oct 2007 18:16:58 GMT
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());
 



Mime
View raw message