tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-636. NPE in ExampleDriver.printDAGStatus(). (hitesh)
Date Fri, 22 Nov 2013 00:40:05 GMT
Updated Branches:
  refs/heads/master c3b736fcd -> b885eca72


TEZ-636. NPE in ExampleDriver.printDAGStatus(). (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/b885eca7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/b885eca7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/b885eca7

Branch: refs/heads/master
Commit: b885eca7289fbc2e3419625ad972339b2e6ba351
Parents: c3b736f
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Nov 21 16:39:43 2013 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Nov 21 16:39:43 2013 -0800

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


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/b885eca7/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
index ff2a804..cb34b2a 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/ExampleDriver.java
@@ -119,6 +119,11 @@ public class ExampleDriver {
       for (String vertexName : vertexNames) {
         VertexStatus vStatus = dagClient.getVertexStatus(vertexName,
           (displayVertexCounters ? opts : null));
+        if (vStatus == null) {
+          System.out.println("Could not retrieve status for vertex: "
+            + vertexName);
+          continue;
+        }
         Progress vProgress = vStatus.getProgress();
         if (vProgress != null) {
           vProgressFloat = 0.0f;


Mime
View raw message