MAPREDUCE-3241. [Rumen] Fix Rumen to ignore the AMStartedEvent. (amarrk)

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.23@1195548 13f79535-47bb-0310-9956-ffa450edef68

hadoop-mapreduce-project/CHANGES.txt

@@ -1,4 +1,6 @@
 Hadoop MapReduce Change Log
+    MAPREDUCE-3241. [Rumen] Fix Rumen to ignore the AMStartedEvent. (amarrk)
+
     MAPREDUCE-3166. [Rumen] Make Rumen use job history api instead of relying
     on current history file name format. (Ravi Gummadi via amarrk)
 

hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java

@@ -28,6 +28,7 @@ import java.util.regex.Pattern;
 
 import org.apache.hadoop.mapred.TaskStatus;
 import org.apache.hadoop.mapreduce.TaskType;
+import org.apache.hadoop.mapreduce.jobhistory.AMStartedEvent;
 import org.apache.hadoop.mapreduce.jobhistory.HistoryEvent;
 import org.apache.hadoop.mapreduce.jobhistory.JobFinishedEvent;
 import org.apache.hadoop.mapreduce.jobhistory.JobInfoChangeEvent;
@@ -129,7 +130,11 @@ public class JobBuilder {
     }
 
     // these are in lexicographical order by class name.
-    if (event instanceof JobFinishedEvent) {
+    if (event instanceof AMStartedEvent) {
+      // ignore this event as Rumen currently doesnt need this event
+      //TODO Enhance Rumen to process this event and capture restarts
+      return;
+    } else if (event instanceof JobFinishedEvent) {
       processJobFinishedEvent((JobFinishedEvent) event);
     } else if (event instanceof JobInfoChangeEvent) {
       processJobInfoChangeEvent((JobInfoChangeEvent) event);