You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2016/06/13 09:36:19 UTC
hbase git commit: Revert HBASE-15991 commit
Repository: hbase
Updated Branches:
refs/heads/master 2738518d4 -> 2d0448fa8
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/master
Commit: 2d0448fa84745991d2447ff78600866873b1fec0
Parents: 2738518
Author: Ramkrishna <ra...@intel.com>
Authored: Mon Jun 13 15:05:50 2016 +0530
Committer: Ramkrishna <ra...@intel.com>
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) {