tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-540. job sometimes fails on launch when using session mode. (hitesh)
Date Thu, 10 Oct 2013 00:47:15 GMT
Updated Branches:
  refs/heads/master d5990a7d2 -> 26d6fd0a2


TEZ-540. job sometimes fails on launch when using session mode. (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/26d6fd0a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/26d6fd0a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/26d6fd0a

Branch: refs/heads/master
Commit: 26d6fd0a2eef89fbde8058713e0a5047267d0f38
Parents: d5990a7
Author: Hitesh Shah <hitesh@apache.org>
Authored: Wed Oct 9 17:46:54 2013 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Wed Oct 9 17:46:54 2013 -0700

----------------------------------------------------------------------
 tez-api/src/main/java/org/apache/tez/client/TezSession.java      | 4 ++++
 .../runtime/library/broadcast/input/BroadcastShuffleManager.java | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/26d6fd0a/tez-api/src/main/java/org/apache/tez/client/TezSession.java
----------------------------------------------------------------------
diff --git a/tez-api/src/main/java/org/apache/tez/client/TezSession.java b/tez-api/src/main/java/org/apache/tez/client/TezSession.java
index 95ee1b5..f10629c 100644
--- a/tez-api/src/main/java/org/apache/tez/client/TezSession.java
+++ b/tez-api/src/main/java/org/apache/tez/client/TezSession.java
@@ -192,6 +192,10 @@ public class TezSession {
    * @throws IOException
    */
   public synchronized void stop() throws TezException, IOException {
+    if (!sessionStarted) {
+      LOG.info("Session not started. Ignoring stop command");
+      return;
+    }
     LOG.info("Shutting down Tez Session"
         + ", sessionName=" + sessionName
         + ", applicationId=" + applicationId);

http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/26d6fd0a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/broadcast/input/BroadcastShuffleManager.java
----------------------------------------------------------------------
diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/broadcast/input/BroadcastShuffleManager.java
b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/broadcast/input/BroadcastShuffleManager.java
index 3cc0eb8..1f0f590 100644
--- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/broadcast/input/BroadcastShuffleManager.java
+++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/broadcast/input/BroadcastShuffleManager.java
@@ -230,7 +230,7 @@ public class BroadcastShuffleManager implements FetcherCallback {
               } else {
                 if (LOG.isDebugEnabled()) {
                   LOG.debug("Skipping host: " + inputHost.getHost()
-                      + " since it has know inputs to process");
+                      + " since it has no inputs to process");
                 }
               }
             }


Mime
View raw message