diff --git a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index 5cae599230..9c7f1ea9d9 100644 --- a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -790,6 +790,9 @@ public void close() { try { if (null != client) { client.shutdown(); + if ((transport == null) || !transport.isOpen()) { + LOG.info("Closed a connection to metastore, current connections: " + connCount.decrementAndGet()); + } } } catch (TException e) { LOG.debug("Unable to shutdown metastore client. Will try closing transport directly.", e); diff --git a/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java b/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java index 7661ae65c9..54aaf180ed 100644 --- a/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java +++ b/standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java @@ -599,6 +599,9 @@ public void close() { try { if (null != client) { client.shutdown(); + if ((transport == null) || !transport.isOpen()) { + LOG.info("Closed a connection to metastore, current connections: " + connCount.decrementAndGet()); + } } } catch (TException e) { LOG.debug("Unable to shutdown metastore client. Will try closing transport directly.", e);