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 be9180c..a360887 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 @@ -237,7 +237,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); @@ -535,10 +535,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);