hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From syuanji...@apache.org
Subject [05/30] hbase git commit: HBASE-15991 CompactingMemstore#InMemoryFlushRunnable should implement Comparable/Comparator (Ram)
Date Fri, 17 Jun 2016 05:01:47 GMT
HBASE-15991 CompactingMemstore#InMemoryFlushRunnable should implement
Comparable/Comparator (Ram)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/56c209c8
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/56c209c8
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/56c209c8

Branch: refs/heads/hbase-12439
Commit: 56c209c8aaf15997888307f8a76767858cb9f470
Parents: 2d0448f
Author: Ramkrishna <ramkrishna.s.vasudevan@intel.com>
Authored: Mon Jun 13 17:42:35 2016 +0530
Committer: Ramkrishna <ramkrishna.s.vasudevan@intel.com>
Committed: Mon Jun 13 17:42:35 2016 +0530

----------------------------------------------------------------------
 .../apache/hadoop/hbase/regionserver/RegionServicesForStores.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/56c209c8/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServicesForStores.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServicesForStores.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServicesForStores.java
index 72f7bf5..e481a63 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServicesForStores.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServicesForStores.java
@@ -18,6 +18,7 @@
  */
 package org.apache.hadoop.hbase.regionserver;
 
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -42,7 +43,7 @@ public class RegionServicesForStores {
   private static final int POOL_SIZE = 10;
   private static final ThreadPoolExecutor INMEMORY_COMPACTION_POOL =
       new ThreadPoolExecutor(POOL_SIZE, POOL_SIZE, 60, TimeUnit.SECONDS,
-          new StealJobQueue<Runnable>().getStealFromQueue(),
+          new LinkedBlockingQueue<Runnable>(),
           new ThreadFactory() {
             @Override
             public Thread newThread(Runnable r) {


Mime
View raw message