From 7e056015add4c742f3571f487ae97f8fd8ac720a Mon Sep 17 00:00:00 2001
From: Amar Kamat <amarrk@apache.org>
Date: Mon, 31 Oct 2011 15:51:32 +0000
Subject: [PATCH] MAPREDUCE-3241. [Rumen] Fix Rumen to ignore the
 AMStartedEvent. (amarrk)

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1195535 13f79535-47bb-0310-9956-ffa450edef68
---
 hadoop-mapreduce-project/CHANGES.txt                       | 2 ++
 .../tools/org/apache/hadoop/tools/rumen/JobBuilder.java    | 7 ++++++-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index 1c8861188d..74a0538565 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -30,6 +30,8 @@ Trunk (unreleased changes)
 
   BUG FIXES
 
+    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)
 
diff --git a/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java b/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
index 9aa9efb802..457889b078 100644
--- a/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
+++ b/hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/JobBuilder.java
@@ -28,6 +28,7 @@
 
 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 void process(HistoryEvent event) {
     }
 
     // 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);