This is an automated email from the ASF dual-hosted git repository.
prasanthj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new e540cf8 HIVE-21212: LLAP: shuffle port config uses internal
configuration (Prasanth Jayachandran reviewed by Gopal V)
e540cf8 is described below
commit e540cf8238680453fc04e861dbc332e7f56b904a
Author: Prasanth Jayachandran <[email protected]>
AuthorDate: Tue Feb 12 00:37:26 2019 -0800
HIVE-21212: LLAP: shuffle port config uses internal configuration (Prasanth
Jayachandran reviewed by Gopal V)
---
.../src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java
b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java
index 2279f8d..41eca8f 100644
---
a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java
+++
b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java
@@ -534,8 +534,7 @@ public class LlapDaemon extends CompositeService implements
ContainerRunner, Lla
new String[0] : StringUtils.getTrimmedStrings(localDirList);
int rpcPort = HiveConf.getIntVar(daemonConf,
ConfVars.LLAP_DAEMON_RPC_PORT);
int mngPort = HiveConf.getIntVar(daemonConf,
ConfVars.LLAP_MANAGEMENT_RPC_PORT);
- int shufflePort = daemonConf
- .getInt(ShuffleHandler.SHUFFLE_PORT_CONFIG_KEY,
ShuffleHandler.DEFAULT_SHUFFLE_PORT);
+ int shufflePort = HiveConf.getIntVar(daemonConf,
ConfVars.LLAP_DAEMON_YARN_SHUFFLE_PORT);
int webPort = HiveConf.getIntVar(daemonConf,
ConfVars.LLAP_DAEMON_WEB_PORT);
LlapDaemonInfo.initialize(appName, daemonConf);