chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r768116 - in /hadoop/chukwa: branches/chukwa-0.1/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/ branches/chukwa-0.1/test/samples/ trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/mapper/ trunk/test/sa...
Date Fri, 24 Apr 2009 01:38:50 GMT
Author: eyang
Date: Fri Apr 24 01:38:49 2009
New Revision: 768116

URL: http://svn.apache.org/viewvc?rev=768116&view=rev
Log:
CHUKWA-187. Correction to status for job and task status. (Cheng Zhang via Eric Yang)

Removed:
    hadoop/chukwa/branches/chukwa-0.1/test/samples/Df_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/branches/chukwa-0.1/test/samples/JobData_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/branches/chukwa-0.1/test/samples/SystemMetrics_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/branches/chukwa-0.1/test/samples/TaskData_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/trunk/test/samples/Df_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/trunk/test/samples/JobData_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/trunk/test/samples/SystemMetrics_HourlyDone_20090422_15.1.evt
    hadoop/chukwa/trunk/test/samples/TaskData_HourlyDone_20090422_15.1.evt
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=768116&r1=768115&r2=768116&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
Fri Apr 24 01:38:49 2009
@@ -175,7 +175,7 @@
 				put("TASK_ATTEMPT_TIMES", "" + getAttempts());
 			}
 			
-			if(get(JobHistory.Keys.FINISH_TIME.toString())!=null) {
+			if(logType.equals("Job") && get(JobHistory.Keys.FINISH_TIME.toString())!=null)
{
 			  put("JOB_FINAL_STATUS", get("JOB_STATUS"));
 			}
 		}

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=768116&r1=768115&r2=768116&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
Fri Apr 24 01:38:49 2009
@@ -175,7 +175,7 @@
 				put("TASK_ATTEMPT_TIMES", "" + getAttempts());
 			}
 			
-			if(get(JobHistory.Keys.FINISH_TIME.toString())!=null) {
+			if(logType.equals("Job") && get(JobHistory.Keys.FINISH_TIME.toString())!=null)
{
 			  put("JOB_FINAL_STATUS", get("JOB_STATUS"));
 			}
 		}



Mime
View raw message