diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java index a8457c696c0..5c92304fa1e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java @@ -238,6 +238,11 @@ class MemStoreFlusher implements FlushRequester { } private class FlushHandler extends HasThread { + + private FlushHandler(String name) { + super(name); + } + @Override public void run() { while (!server.isStopped()) { @@ -381,7 +386,7 @@ class MemStoreFlusher implements FlushRequester { ThreadFactory flusherThreadFactory = Threads.newDaemonThreadFactory( server.getServerName().toShortString() + "-MemStoreFlusher", eh); for (int i = 0; i < flushHandlers.length; i++) { - flushHandlers[i] = new FlushHandler(); + flushHandlers[i] = new FlushHandler("MemStoreFlusher." + i); flusherThreadFactory.newThread(flushHandlers[i]); flushHandlers[i].start(); }