You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/03/14 19:23:01 UTC
git commit: TEZ-931. DAGHistoryEvent should not be allowed to be sent
to Dispatcher/EventHandlers. (hitesh)
Repository: incubator-tez
Updated Branches:
refs/heads/master f58508a56 -> 537d3bca4
TEZ-931. DAGHistoryEvent should not be allowed to be sent to Dispatcher/EventHandlers. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/537d3bca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/537d3bca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/537d3bca
Branch: refs/heads/master
Commit: 537d3bca4cd72d50be07b6ccdac7312ab2a8daf7
Parents: f58508a
Author: Hitesh Shah <hi...@apache.org>
Authored: Fri Mar 14 11:22:36 2014 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Fri Mar 14 11:22:36 2014 -0700
----------------------------------------------------------------------
.../main/java/org/apache/tez/dag/history/DAGHistoryEvent.java | 5 ++---
.../java/org/apache/tez/dag/history/HistoryEventHandler.java | 2 +-
2 files changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/537d3bca/tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java b/tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java
index 54a686d..dfa6bbd 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java
@@ -18,17 +18,15 @@
package org.apache.tez.dag.history;
-import org.apache.hadoop.yarn.event.AbstractEvent;
import org.apache.tez.dag.records.TezDAGID;
-public class DAGHistoryEvent extends AbstractEvent<HistoryEventType>{
+public class DAGHistoryEvent {
private final HistoryEvent historyEvent;
private final TezDAGID dagID;
public DAGHistoryEvent(TezDAGID dagID,
HistoryEvent historyEvent) {
- super(historyEvent.getEventType());
this.dagID = dagID;
this.historyEvent = historyEvent;
}
@@ -44,4 +42,5 @@ public class DAGHistoryEvent extends AbstractEvent<HistoryEventType>{
public TezDAGID getDagID() {
return this.dagID;
}
+
}
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/537d3bca/tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java b/tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java
index b64cf1a..866cdc4 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java
@@ -98,7 +98,7 @@ public class HistoryEventHandler extends CompositeService {
// there is a UI in place
LOG.info("[HISTORY]"
+ "[DAG:" + dagIdStr + "]"
- + "[Event:" + event.getType().name() + "]"
+ + "[Event:" + event.getHistoryEvent().getEventType().name() + "]"
+ ": " + event.getHistoryEvent().toString());
}