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 <prasan...@apache.org>
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);

Reply via email to