tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-267. Crash in YARNRunner because of NULL dagClient (bikas).
Date Thu, 20 Jun 2013 17:09:26 GMT
Updated Branches:
  refs/heads/master e81396036 -> c8c315b0e


TEZ-267. Crash in YARNRunner because of NULL dagClient (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/c8c315b0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/c8c315b0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/c8c315b0

Branch: refs/heads/master
Commit: c8c315b0ecb79e1dcf237341d5417b571fbde1ea
Parents: e813960
Author: Bikas Saha <bikas@apache.org>
Authored: Thu Jun 20 10:05:42 2013 -0700
Committer: Bikas Saha <bikas@apache.org>
Committed: Thu Jun 20 10:05:42 2013 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/tez/mapreduce/YARNRunner.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/c8c315b0/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java
----------------------------------------------------------------------
diff --git a/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java b/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java
index 8de897f..fb29918 100644
--- a/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java
+++ b/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/YARNRunner.java
@@ -615,7 +615,7 @@ public class YARNRunner implements ClientProtocol {
     DAGStatus dagStatus;
     try {
       if(dagClient == null) {
-        dagClient = tezClient.getDAGClient(resMgrDelegate.getApplicationId());
+        dagClient = tezClient.getDAGClient(TypeConverter.toYarn(jobID).getAppId());
       }
       dagStatus = dagClient.getDAGStatus();
       return new DAGJobStatus(dagClient.getApplicationReport(), dagStatus, jobFile);


Mime
View raw message