chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r768141 - 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 Fri, 24 Apr 2009 05:56:56 GMT
Author: eyang
Date: Fri Apr 24 05:56:54 2009
New Revision: 768141

URL: http://svn.apache.org/viewvc?rev=768141&view=rev
Log:
CHUKWA-187. Fix JobData type.

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=768141&r1=768140&r2=768141&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 05:56:54 2009
@@ -175,7 +175,7 @@
 				put("TASK_ATTEMPT_TIMES", "" + getAttempts());
 			}
 			
-			if(logType.equals("Job") && get(JobHistory.Keys.FINISH_TIME.toString())!=null)
{
+			if(logType.equals("JobData") && 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=768141&r1=768140&r2=768141&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 05:56:54 2009
@@ -175,7 +175,7 @@
 				put("TASK_ATTEMPT_TIMES", "" + getAttempts());
 			}
 			
-			if(logType.equals("Job") && get(JobHistory.Keys.FINISH_TIME.toString())!=null)
{
+			if(logType.equals("JobData") && get(JobHistory.Keys.FINISH_TIME.toString())!=null)
{
 			  put("JOB_FINAL_STATUS", get("JOB_STATUS"));
 			}
 		}



Mime
View raw message