diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 96971be..26fd98e 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -470,7 +470,7 @@ public class HiveMetaStore extends ThriftHiveMetastore { RawStore ms = threadLocalMS.get(); if (ms != null) { ms.shutdown(); - ms = null; + threadLocalMS.remove(); } logInfo("Metastore shutdown complete."); }