Index: src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java (revision 1182081) +++ src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java (working copy) @@ -355,10 +355,11 @@ // Note: We don't impose blockingStoreFiles constraint on meta regions LOG.warn("Region " + region.getRegionNameAsString() + " has too many " + "store files; delaying flush up to " + this.blockingWaitTime + "ms"); + if (!this.server.compactSplitThread.requestSplit(region)) { + this.server.compactSplitThread.requestCompaction(region, getName()); + } } - if (!this.server.compactSplitThread.requestSplit(region)) { - this.server.compactSplitThread.requestCompaction(region, getName()); - } + // Put back on the queue. Have it come back out of the queue // after a delay of this.blockingWaitTime / 100 ms. this.flushQueue.add(fqe.requeue(this.blockingWaitTime / 100)); Index: src/main/java/org/apache/hadoop/hbase/regionserver/Store.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (revision 1182081) +++ src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (working copy) @@ -1002,7 +1002,8 @@ } if (filesToCompact.isEmpty()) { - LOG.debug(this.storeNameStr + ": no store files to compact"); + LOG.debug(this.getHRegionInfo().getEncodedName() + " - " + + this.storeNameStr + ": no store files to compact"); return filesToCompact; }