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 <[email protected]> Authored: Mon Jun 13 17:42:35 2016 +0530 Committer: Ramkrishna <[email protected]> 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) {
