You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by ey...@apache.org on 2009/04/23 00:46:14 UTC
svn commit: r767700 - in /hadoop/chukwa:
branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
Author: eyang
Date: Wed Apr 22 22:46:14 2009
New Revision: 767700
URL: http://svn.apache.org/viewvc?rev=767700&view=rev
Log:
CHUKWA-155. Store final job status only (Cheng Zhang via Eric Yang)
Modified:
hadoop/chukwa/branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
Modified: hadoop/chukwa/branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java?rev=767700&r1=767699&r2=767700&view=diff
==============================================================================
--- hadoop/chukwa/branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java (original)
+++ hadoop/chukwa/branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java Wed Apr 22 22:46:14 2009
@@ -174,6 +174,10 @@
if(get("TASK_ATTEMPT_ID") != null) {
put("TASK_ATTEMPT_TIMES", "" + getAttempts());
}
+
+ if(get(JobHistory.Keys.FINISH_TIME.toString())!=null) {
+ put("JOB_FINAL_STATUS", get("JOB_STATUS"));
+ }
}
public String getLogType() {
Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java?rev=767700&r1=767699&r2=767700&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java (original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/JobLog.java Wed Apr 22 22:46:14 2009
@@ -174,6 +174,10 @@
if(get("TASK_ATTEMPT_ID") != null) {
put("TASK_ATTEMPT_TIMES", "" + getAttempts());
}
+
+ if(get(JobHistory.Keys.FINISH_TIME.toString())!=null) {
+ put("JOB_FINAL_STATUS", get("JOB_STATUS"));
+ }
}
public String getLogType() {