Index: src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java (revision 1024102) +++ src/main/java/org/apache/hadoop/hbase/regionserver/CompactSplitThread.java (working copy) @@ -159,13 +159,12 @@ return; } r.setForceMajorCompaction(force); - if (LOG.isDebugEnabled()) { + if (compactionQueue.add(r, priority) && LOG.isDebugEnabled()) { LOG.debug("Compaction " + (force? "(major) ": "") + "requested for region " + r.getRegionNameAsString() + (why != null && !why.isEmpty()? " because: " + why: "") + "; Priority: " + priority + "; Compaction queue size: " + compactionQueue.size()); } - compactionQueue.add(r, priority); } private void split(final HRegion parent, final byte [] midKey)