Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-4579 CST.requestCompaction semantics changed, logs are now 

spammed when too many store files


git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1185316 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2011-10-17 18:19:18 +00:00
parent ef6532498b
commit 8fa3959795
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
View File

@ -355,10 +355,11 @@ class MemStoreFlusher extends Thread implements FlushRequester {
// Note: We don't impose blockingStoreFiles constraint on meta regions // Note: We don't impose blockingStoreFiles constraint on meta regions
LOG.warn("Region " + region.getRegionNameAsString() + " has too many " + LOG.warn("Region " + region.getRegionNameAsString() + " has too many " +
"store files; delaying flush up to " + this.blockingWaitTime + "ms"); "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 // Put back on the queue. Have it come back out of the queue
// after a delay of this.blockingWaitTime / 100 ms. // after a delay of this.blockingWaitTime / 100 ms.
this.flushQueue.add(fqe.requeue(this.blockingWaitTime / 100)); this.flushQueue.add(fqe.requeue(this.blockingWaitTime / 100));

3
src/main/java/org/apache/hadoop/hbase/regionserver/Store.java
View File

@ -1003,7 +1003,8 @@ public class Store implements HeapSize {
} }
if (filesToCompact.isEmpty()) { 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; return filesToCompact;
} }