tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-197 Fix build break by YARN-686 (flatten node report) (bikas)
Date Mon, 10 Jun 2013 00:35:07 GMT
Updated Branches:
  refs/heads/master f4346dc80 -> ca1e53e89


TEZ-197 Fix build break by YARN-686 (flatten node report) (bikas)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/ca1e53e8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ca1e53e8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ca1e53e8

Branch: refs/heads/master
Commit: ca1e53e891941c79f85f6bd478318ef92407962c
Parents: f4346dc
Author: Bikas Saha <bikas@apache.org>
Authored: Sun Jun 9 17:32:09 2013 -0700
Committer: Bikas Saha <bikas@apache.org>
Committed: Sun Jun 9 17:32:09 2013 -0700

----------------------------------------------------------------------
 .../apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ca1e53e8/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java
b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java
index 9ae9617..ca4e5bd 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java
@@ -24,9 +24,10 @@ public class AMNodeEventStateChanged extends AMNodeEvent {
   private NodeReport nodeReport;
 
   public AMNodeEventStateChanged(NodeReport nodeReport) {
-    super(nodeReport.getNodeId(), nodeReport.getNodeHealthStatus()
-        .getIsNodeHealthy() ? AMNodeEventType.N_TURNED_HEALTHY
-        : AMNodeEventType.N_TURNED_UNHEALTHY);
+    super(nodeReport.getNodeId(), 
+          (nodeReport.getNodeState().isUnusable() ? 
+              AMNodeEventType.N_TURNED_UNHEALTHY :
+              AMNodeEventType.N_TURNED_HEALTHY));
     this.nodeReport = nodeReport;
   }
 


Mime
View raw message