diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java index 3e73ec1..efa5b60 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java @@ -215,7 +215,7 @@ public class CompactSplitThread implements CompactionRequestor { public synchronized boolean requestSplit(final HRegion r) { // don't split regions that are blocking - if (shouldSplitRegion() && r.getCompactPriority() >= Store.PRIORITY_USER) { + if (shouldSplitRegion()) { byte[] midKey = r.checkSplit(); if (midKey != null) { requestSplit(r, midKey); @@ -507,10 +507,9 @@ public class CompactSplitThread implements CompactionRequestor { // degenerate case: blocked regions require recursive enqueues if (store.getCompactPriority() <= 0) { requestSystemCompaction(region, store, "Recursive enqueue"); - } else { - // see if the compaction has caused us to exceed max region size - requestSplit(region); } + // see if the compaction has caused us to exceed max region size + requestSplit(region); } } catch (IOException ex) { IOException remoteEx = RemoteExceptionHandler.checkIOException(ex);