You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/05/25 20:49:45 UTC

[06/31] hive git commit: HIVE-16554: ACID: Make HouseKeeperService threads daemon (Vaibhav Gumashta reviewed by Eugene Koifman)

HIVE-16554: ACID: Make HouseKeeperService threads daemon (Vaibhav Gumashta reviewed by Eugene Koifman)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/823f01c3
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/823f01c3
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/823f01c3

Branch: refs/heads/hive-14535
Commit: 823f01c386989eed2b5c60492f16140521b583a8
Parents: 3c1b354
Author: Vaibhav Gumashta <vg...@hortonworks.com>
Authored: Thu May 25 00:53:09 2017 -0700
Committer: Vaibhav Gumashta <vg...@hortonworks.com>
Committed: Thu May 25 00:53:09 2017 -0700

----------------------------------------------------------------------
 .../hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/823f01c3/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java b/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java
index 0b7332c..0aa160c 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/HouseKeeperServiceBase.java
@@ -48,7 +48,11 @@ public abstract class HouseKeeperServiceBase implements HouseKeeperService {
       private final AtomicInteger threadCounter = new AtomicInteger();
       @Override
       public Thread newThread(Runnable r) {
-        return new Thread(r, HouseKeeperServiceBase.this.getClass().getName() + "-" + threadCounter.getAndIncrement());
+        Thread t =
+            new Thread(r, HouseKeeperServiceBase.this.getClass().getName() + "-"
+                + threadCounter.getAndIncrement());
+        t.setDaemon(true);
+        return t;
       }
     });