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();
     }