You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2013/11/05 23:10:46 UTC
svn commit: r1539153 -
/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java
Author: gunther
Date: Tue Nov 5 22:10:45 2013
New Revision: 1539153
URL: http://svn.apache.org/r1539153
Log:
HIVE-5750: Queue name should not be hardcoded to 'default' when running Tez jobs (Siddharth Seth via Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java
Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java?rev=1539153&r1=1539152&r2=1539153&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java Tue Nov 5 22:10:45 2013
@@ -33,9 +33,6 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.DistributedFileSystem;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.ErrorMsg;
-import org.apache.hadoop.hive.ql.metadata.Hive;
-import org.apache.hadoop.hive.ql.metadata.HiveException;
-import org.apache.hadoop.hive.shims.ShimLoader;
import org.apache.hadoop.yarn.api.records.LocalResource;
import org.apache.tez.client.AMConfiguration;
import org.apache.tez.client.TezSession;
@@ -93,9 +90,6 @@ public class TezSessionState {
// generate basic tez config
TezConfiguration tezConfig = new TezConfiguration(conf);
- tezConfig.set(TezConfiguration.TEZ_AM_JAVA_OPTS,
- MRHelpers.getMRAMJavaOpts(conf));
-
tezConfig.set(TezConfiguration.TEZ_AM_STAGING_DIR, tezScratchDir.toUri().toString());
// unless already installed on all the cluster nodes, we'll have to
@@ -106,7 +100,7 @@ public class TezSessionState {
Map<String, LocalResource> commonLocalResources = new HashMap<String, LocalResource>();
commonLocalResources.put(DagUtils.getBaseName(appJarLr), appJarLr);
- AMConfiguration amConfig = new AMConfiguration("default", null, commonLocalResources,
+ AMConfiguration amConfig = new AMConfiguration(null, commonLocalResources,
tezConfig, null);
// configuration for the session