Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-10563 Set name for FlushHandler thread (Himanshu Vashishtha) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1569370 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
mbertozzi 2014-02-18 15:00:15 +00:00
parent e8e5a7a881
commit 8c24e585e1
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
View File

@ -238,6 +238,11 @@ class MemStoreFlusher implements FlushRequester {
} }
private class FlushHandler extends HasThread { private class FlushHandler extends HasThread {
private FlushHandler(String name) {
super(name);
}
@Override @Override
public void run() { public void run() {
while (!server.isStopped()) { while (!server.isStopped()) {
@ -381,7 +386,7 @@ class MemStoreFlusher implements FlushRequester {
ThreadFactory flusherThreadFactory = Threads.newDaemonThreadFactory( ThreadFactory flusherThreadFactory = Threads.newDaemonThreadFactory(
server.getServerName().toShortString() + "-MemStoreFlusher", eh); server.getServerName().toShortString() + "-MemStoreFlusher", eh);
for (int i = 0; i < flushHandlers.length; i++) { for (int i = 0; i < flushHandlers.length; i++) {
flushHandlers[i] = new FlushHandler(); flushHandlers[i] = new FlushHandler("MemStoreFlusher." + i);
flusherThreadFactory.newThread(flushHandlers[i]); flusherThreadFactory.newThread(flushHandlers[i]);
flushHandlers[i].start(); flushHandlers[i].start();
} }