HBASE-14185 Incorrect region names logged by MemStoreFlusher (Biju Nair)
This commit is contained in:
parent
1b0b67fb7c
commit
a0d72051db
|
@ -197,12 +197,12 @@ class MemStoreFlusher implements FlushRequester {
|
||||||
ServerRegionReplicaUtil.isRegionReplicaStoreFileRefreshEnabled(conf) &&
|
ServerRegionReplicaUtil.isRegionReplicaStoreFileRefreshEnabled(conf) &&
|
||||||
(bestRegionReplica.getMemstoreSize()
|
(bestRegionReplica.getMemstoreSize()
|
||||||
> secondaryMultiplier * regionToFlush.getMemstoreSize()))) {
|
> secondaryMultiplier * regionToFlush.getMemstoreSize()))) {
|
||||||
LOG.info("Refreshing storefiles of region " + regionToFlush +
|
LOG.info("Refreshing storefiles of region " + bestRegionReplica +
|
||||||
" due to global heap pressure. memstore size=" + StringUtils.humanReadableInt(
|
" due to global heap pressure. memstore size=" + StringUtils.humanReadableInt(
|
||||||
server.getRegionServerAccounting().getGlobalMemstoreSize()));
|
server.getRegionServerAccounting().getGlobalMemstoreSize()));
|
||||||
flushedOne = refreshStoreFilesAndReclaimMemory(bestRegionReplica);
|
flushedOne = refreshStoreFilesAndReclaimMemory(bestRegionReplica);
|
||||||
if (!flushedOne) {
|
if (!flushedOne) {
|
||||||
LOG.info("Excluding secondary region " + regionToFlush +
|
LOG.info("Excluding secondary region " + bestRegionReplica +
|
||||||
" - trying to find a different region to refresh files.");
|
" - trying to find a different region to refresh files.");
|
||||||
excludedRegions.add(bestRegionReplica);
|
excludedRegions.add(bestRegionReplica);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue