You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ek...@apache.org on 2016/09/20 00:14:17 UTC
hive git commit: HIVE-14779 make DbTxnManager.HeartbeaterThread a
daemon (Eugene Koifman, reviewed by Alan Gates)
Repository: hive
Updated Branches:
refs/heads/master eab7b40c7 -> 3c55115b6
HIVE-14779 make DbTxnManager.HeartbeaterThread a daemon (Eugene Koifman, reviewed by Alan Gates)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/3c55115b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/3c55115b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/3c55115b
Branch: refs/heads/master
Commit: 3c55115b6eaaa02442c9c487d5d328275e211567
Parents: eab7b40
Author: Eugene Koifman <ek...@hortonworks.com>
Authored: Mon Sep 19 17:14:03 2016 -0700
Committer: Eugene Koifman <ek...@hortonworks.com>
Committed: Mon Sep 19 17:14:03 2016 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/3c55115b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/DbTxnManager.java
----------------------------------------------------------------------
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 class DbTxnManager extends HiveTxnManagerImpl {
};
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 class DbTxnManager extends HiveTxnManagerImpl {
public static class HeartbeaterThread extends Thread {
public HeartbeaterThread(Runnable target, String name) {
super(target, name);
+ setDaemon(true);
}
@Override