hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mberto...@apache.org
Subject svn commit: r1569370 - /hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Date Tue, 18 Feb 2014 15:00:15 GMT
Author: mbertozzi
Date: Tue Feb 18 15:00:15 2014
New Revision: 1569370

URL: http://svn.apache.org/r1569370
Log:
HBASE-10563 Set name for FlushHandler thread (Himanshu Vashishtha)

Modified:
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java?rev=1569370&r1=1569369&r2=1569370&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
Tue Feb 18 15:00:15 2014
@@ -238,6 +238,11 @@ class MemStoreFlusher implements FlushRe
   }
 
   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 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();
     }



Mime
View raw message