You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2016/06/17 05:01:45 UTC
[03/30] hbase git commit: HBASE-15991
CompactingMemstore#InMemoryFlushRunnable should implement
Comparable/Comparator (Ram)
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/2738518d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2738518d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2738518d
Branch: refs/heads/hbase-12439
Commit: 2738518d439e881ff57622b10ba835dbaab25c77
Parents: 6360cc0
Author: Ramkrishna <ra...@intel.com>
Authored: Mon Jun 13 12:43:52 2016 +0530
Committer: Ramkrishna <ra...@intel.com>
Committed: Mon Jun 13 12:43:52 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/2738518d/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) {