Revert HBASE-15991 commit
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2d0448fa Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2d0448fa Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2d0448fa Branch: refs/heads/hbase-12439 Commit: 2d0448fa84745991d2447ff78600866873b1fec0 Parents: 2738518 Author: Ramkrishna <[email protected]> Authored: Mon Jun 13 15:05:50 2016 +0530 Committer: Ramkrishna <[email protected]> Committed: Mon Jun 13 15:05:50 2016 +0530 ---------------------------------------------------------------------- .../apache/hadoop/hbase/regionserver/RegionServicesForStores.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/2d0448fa/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 e481a63..72f7bf5 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,7 +18,6 @@ */ 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; @@ -43,7 +42,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 LinkedBlockingQueue<Runnable>(), + new StealJobQueue<Runnable>().getStealFromQueue(), new ThreadFactory() { @Override public Thread newThread(Runnable r) {
