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