chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject 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
Date Wed, 22 Apr 2009 22:46:14 GMT
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() {



Mime
View raw message