diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/LossyCounting.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/LossyCounting.java index 95e974933..42cf21b89 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/LossyCounting.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/LossyCounting.java @@ -20,6 +20,8 @@ package org.apache.hadoop.hbase.util; import com.google.common.annotations.VisibleForTesting; +import com.google.common.util.concurrent.ThreadFactoryBuilder; + import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; @@ -72,7 +74,7 @@ public class LossyCounting { this.data = new ConcurrentHashMap<>(); this.listener = listener; calculateCurrentTerm(); - executor = Executors.newSingleThreadExecutor(); + executor = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setDaemon(true).setNameFormat("lossy-count-%d").build()); } public LossyCounting(String name, LossyCountingListener listener) {