diff --git a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java index a446999..da7505b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java @@ -105,7 +105,7 @@ public synchronized void remove() { }; private static AtomicInteger heartbeaterMSClientCount = new AtomicInteger(0); - private int heartbeaterThreadPoolSize = 0; + private static int heartbeaterThreadPoolSize = 0; private static SynchronizedMetaStoreClient getThreadLocalMSClient() { return threadLocalMSClient.get(); @@ -625,6 +625,7 @@ public Thread newThread(Runnable r) { public static class HeartbeaterThread extends Thread { public HeartbeaterThread(Runnable target, String name) { super(target, name); + setDaemon(true); } @Override