HIVE-21212: LLAP: shuffle port config uses internal configuration (Prasanth Jayachand...
authorPrasanth Jayachandran <prasanthj@apache.org>
Tue, 12 Feb 2019 08:37:26 +0000 (00:37 -0800)
committerPrasanth Jayachandran <prasanthj@apache.org>
Tue, 12 Feb 2019 08:37:39 +0000 (00:37 -0800)
llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java

index 2279f8d..41eca8f 100644 (file)
@@ -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);