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 2d0cc5b..04bb634 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 @@ -235,7 +235,7 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi public synchronized boolean requestSplit(final Region r) { // don't split regions that are blocking - if (shouldSplitRegion() && ((HRegion)r).getCompactPriority() >= Store.PRIORITY_USER) { + if (shouldSplitRegion()) { byte[] midKey = ((HRegion)r).checkSplit(); if (midKey != null) { requestSplit(r, midKey); @@ -530,10 +530,9 @@ public class CompactSplitThread implements CompactionRequestor, PropagatingConfi // 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);