You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mb...@apache.org on 2014/02/18 16:00:42 UTC
svn commit: r1569372 -
/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Author: mbertozzi
Date: Tue Feb 18 15:00:42 2014
New Revision: 1569372
URL: http://svn.apache.org/r1569372
Log:
HBASE-10563 Set name for FlushHandler thread (Himanshu Vashishtha)
Modified:
hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Modified: hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java?rev=1569372&r1=1569371&r2=1569372&view=diff
==============================================================================
--- hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java (original)
+++ hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java Tue Feb 18 15:00:42 2014
@@ -219,6 +219,11 @@ class MemStoreFlusher implements FlushRe
}
private class FlushHandler extends HasThread {
+
+ private FlushHandler(String name) {
+ super(name);
+ }
+
@Override
public void run() {
while (!server.isStopped()) {
@@ -362,7 +367,7 @@ class MemStoreFlusher implements FlushRe
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();
}