tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject tez git commit: TEZ-1928. Tez local mode hang in Pig tez local mode. (hitesh)
Date Mon, 09 Feb 2015 23:02:37 GMT
Repository: tez
Updated Branches:
  refs/heads/master 3da9566de -> 28941dc7f


TEZ-1928. Tez local mode hang in Pig tez local mode. (hitesh)


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

Branch: refs/heads/master
Commit: 28941dc7fe0df3991dbf20ff4bfe7e0e01ec15f3
Parents: 3da9566
Author: Hitesh Shah <hitesh@apache.org>
Authored: Mon Feb 9 15:02:25 2015 -0800
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Mon Feb 9 15:02:25 2015 -0800

----------------------------------------------------------------------
 CHANGES.txt                                                  | 1 +
 tez-dag/src/main/java/org/apache/tez/client/LocalClient.java | 3 +++
 2 files changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/28941dc7/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index a1b42a8..40668e1 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -181,6 +181,7 @@ TEZ-UI CHANGES (TEZ-8):
 Release 0.5.4: Unreleased
 
 ALL CHANGES:
+  TEZ-1928. Tez local mode hang in Pig tez local mode.
   TEZ-1893. Verify invalid -1 parallelism in DAG.verify().
   TEZ-900. Confusing message for incorrect queue for some tez examples.
   TEZ-2036. OneToOneEdgeManager should enforce that source and destination

http://git-wip-us.apache.org/repos/asf/tez/blob/28941dc7/tez-dag/src/main/java/org/apache/tez/client/LocalClient.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/client/LocalClient.java b/tez-dag/src/main/java/org/apache/tez/client/LocalClient.java
index f309b02..1956f0d 100644
--- a/tez-dag/src/main/java/org/apache/tez/client/LocalClient.java
+++ b/tez-dag/src/main/java/org/apache/tez/client/LocalClient.java
@@ -68,6 +68,8 @@ public class LocalClient extends FrameworkClient {
   private boolean isSession;
   private TezApiVersionInfo versionInfo = new TezApiVersionInfo();
   private volatile Throwable amFailException = null;
+  private static final String localModeDAGSchedulerClassName =
+      "org.apache.tez.dag.app.dag.impl.DAGSchedulerNaturalOrderControlled";
 
   public LocalClient() {
   }
@@ -78,6 +80,7 @@ public class LocalClient extends FrameworkClient {
     tezConf.set("fs.defaultFS", "file:///");
     // Tez libs already in the client's classpath
     tezConf.setBoolean(TezConfiguration.TEZ_IGNORE_LIB_URIS, true);
+    tezConf.set(TezConfiguration.TEZ_AM_DAG_SCHEDULER_CLASS, localModeDAGSchedulerClassName);
     isSession = tezConf.getBoolean(TezConfiguration.TEZ_AM_SESSION_MODE,
         TezConfiguration.TEZ_AM_SESSION_MODE_DEFAULT);
   }


Mime
View raw message