diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index a835f6a..00602e1 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -5978,8 +5978,6 @@ public static void startMetaStore(int port, HadoopThriftAuthBridge bridge, boolean useCompactProtocol = conf.getBoolVar(ConfVars.METASTORE_USE_THRIFT_COMPACT_PROTOCOL); useSasl = conf.getBoolVar(HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL); - TServerTransport serverTransport = tcpKeepAlive ? - new TServerSocketKeepAlive(port) : new TServerSocket(port); TProcessor processor; TTransportFactory transFactory; @@ -6027,6 +6025,9 @@ public static void startMetaStore(int port, HadoopThriftAuthBridge bridge, LOG.info("Starting DB backed MetaStore Server"); } } + + TServerTransport serverTransport = tcpKeepAlive ? + new TServerSocketKeepAlive(port) : new TServerSocket(port); TThreadPoolServer.Args args = new TThreadPoolServer.Args(serverTransport) .processor(processor)