diff --git conf/hive-site.xml conf/hive-site.xml index dab494e..593c9e9 100644 --- conf/hive-site.xml +++ conf/hive-site.xml @@ -1,22 +1,7 @@ - - - - + - + +hive.server2.thrift.port +18001 + diff --git service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java index df2d3a7..103485f 100644 --- service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java +++ service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java @@ -155,7 +155,8 @@ public void processContext(ServerContext serverContext, TTransport input, TTrans currentServerContext.set(serverContext); } }); - String msg = "Starting " + ThriftBinaryCLIService.class.getSimpleName() + " on port " + portNum + " with " + String msg = "Starting " + ThriftBinaryCLIService.class.getSimpleName() + " on port " + + serverSocket.getServerSocket().getLocalPort() + " with " + minWorkerThreads + "..." + maxWorkerThreads + " worker threads"; LOG.info(msg); } catch (Exception e) { diff --git service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java index 89271d7..652c265 100644 --- service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java +++ service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java @@ -190,7 +190,7 @@ public void onClosed(Connection connection) { // Finally, start the server server.start(); String msg = "Started " + ThriftHttpCLIService.class.getSimpleName() + " in " + schemeName - + " mode on port " + portNum + " path=" + httpPath + " with " + minWorkerThreads + "..." + + " mode on port " + connector.getLocalPort() + " path=" + httpPath + " with " + minWorkerThreads + "..." + maxWorkerThreads + " worker threads"; LOG.info(msg); } catch (Exception e) {