tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-663. Log DAG diagnostics when OrderedWordCount fails. (hitesh)
Date Fri, 06 Dec 2013 02:34:56 GMT
Updated Branches:
  refs/heads/master c250b5b9d -> 2600a28cd


TEZ-663. Log DAG diagnostics when OrderedWordCount fails. (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/2600a28c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/2600a28c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/2600a28c

Branch: refs/heads/master
Commit: 2600a28cd2a1604c2eac81aadba03bd6c585e87d
Parents: c250b5b
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Dec 5 18:34:27 2013 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Dec 5 18:34:27 2013 -0800

----------------------------------------------------------------------
 .../java/org/apache/tez/mapreduce/examples/OrderedWordCount.java | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/2600a28c/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
index dbf7eb9..c9f81f8 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
@@ -443,6 +443,10 @@ public class OrderedWordCount {
             true, true);
         LOG.info("DAG " + dagIndex + " completed. "
             + "FinalState=" + dagStatus.getState());
+        if (dagStatus.getState() != DAGStatus.State.SUCCEEDED) {
+          LOG.info("DAG " + dagIndex + " diagnostics: "
+            + dagStatus.getDiagnostics());
+        }
       }
     } finally {
       fs.delete(stagingDir, true);


Mime
View raw message