This is an automated email from the ASF dual-hosted git repository.

dengzh 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 d411e500bff HIVE-27865: HMS in http mode drops down silently with no 
errors (#4866) (Zhihua Deng, reviewed by Ayush Saxena, Attila Turoczy)
d411e500bff is described below

commit d411e500bfff023d0f97c796432341805ab0ddb7
Author: dengzh <[email protected]>
AuthorDate: Wed Nov 22 00:07:48 2023 +0800

    HIVE-27865: HMS in http mode drops down silently with no errors (#4866) 
(Zhihua Deng, reviewed by Ayush Saxena, Attila Turoczy)
---
 .../hadoop/hive/metastore/HiveMetaStore.java       | 25 +++++++++-------------
 1 file changed, 10 insertions(+), 15 deletions(-)

diff --git 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
index ecf9904af9d..986bb2e4e84 100644
--- 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
+++ 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
@@ -490,13 +490,11 @@ public class HiveMetaStore extends ThriftHiveMetastore {
         HMSHandler.LOG.debug("Starting HTTPServer for HMS");
         server.setStopAtShutdown(true);
         server.start();
-        HMSHandler.LOG.info("Started the new HTTPServer for metastore on port 
[" + port
-            + "]...");
-        HMSHandler.LOG.info("Options.minWorkerThreads = "
-            + minWorkerThreads);
-        HMSHandler.LOG.info("Options.maxWorkerThreads = "
-            + maxWorkerThreads);
-        HMSHandler.LOG.info("Enable SSL = " + (sslContextFactory != null));
+        HMSHandler.LOG.info("Started the new HTTPServer for metastore on port 
[{}]...", port);
+        HMSHandler.LOG.info("Options.minWorkerThreads = {}", minWorkerThreads);
+        HMSHandler.LOG.info("Options.maxWorkerThreads = {}", maxWorkerThreads);
+        HMSHandler.LOG.info("Enable SSL = {}", (sslContextFactory != null));
+        server.join();
       }
 
       @Override
@@ -642,15 +640,12 @@ public class HiveMetaStore extends ThriftHiveMetastore {
     return new ThriftServer() {
       @Override
       public void start() throws Throwable {
+        HMSHandler.LOG.info("Started the new metaserver on port [{}]...", 
port);
+        HMSHandler.LOG.info("Options.minWorkerThreads = {}", minWorkerThreads);
+        HMSHandler.LOG.info("Options.maxWorkerThreads = {}", maxWorkerThreads);
+        HMSHandler.LOG.info("TCP keepalive = {}", tcpKeepAlive);
+        HMSHandler.LOG.info("Enable SSL = {}", useSSL);
         tServer.serve();
-        HMSHandler.LOG.info("Started the new metaserver on port [" + port
-            + "]...");
-        HMSHandler.LOG.info("Options.minWorkerThreads = "
-            + minWorkerThreads);
-        HMSHandler.LOG.info("Options.maxWorkerThreads = "
-            + maxWorkerThreads);
-        HMSHandler.LOG.info("TCP keepalive = " + tcpKeepAlive);
-        HMSHandler.LOG.info("Enable SSL = " + useSSL);
       }
 
       @Override

Reply via email to