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

HBASE-7001 Fix the RCN Correctness Warning in MemStoreFlusher class (Liang Xie) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1401037 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2012-10-22 19:34:12 +00:00
parent 12315b8597
commit 2cdb599c36
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
View File

@ -350,7 +350,7 @@ class MemStoreFlusher extends HasThread implements FlushRequester {
*/ */
private boolean flushRegion(final FlushRegionEntry fqe) { private boolean flushRegion(final FlushRegionEntry fqe) {
HRegion region = fqe.region; HRegion region = fqe.region;
if (!fqe.region.getRegionInfo().isMetaRegion() && if (!region.getRegionInfo().isMetaRegion() &&
isTooManyStoreFiles(region)) { isTooManyStoreFiles(region)) {
if (fqe.isMaximumWait(this.blockingWaitTime)) { if (fqe.isMaximumWait(this.blockingWaitTime)) {
LOG.info("Waited " + (System.currentTimeMillis() - fqe.createTime) + LOG.info("Waited " + (System.currentTimeMillis() - fqe.createTime) +
@ -366,9 +366,9 @@ class MemStoreFlusher extends HasThread implements FlushRequester {
if (!this.server.compactSplitThread.requestSplit(region)) { if (!this.server.compactSplitThread.requestSplit(region)) {
try { try {
this.server.compactSplitThread.requestCompaction(region, getName()); this.server.compactSplitThread.requestCompaction(region, getName());
} catch (IOException e) { } catch (IOException e) {
LOG.error("Cache flush failed" + LOG.error(
(region != null ? (" for region " + Bytes.toStringBinary(region.getRegionName())) : ""), "Cache flush failed for region " + Bytes.toStringBinary(region.getRegionName()),
RemoteExceptionHandler.checkIOException(e)); RemoteExceptionHandler.checkIOException(e));
} }
} }