HBASE-16675 Average region size may be incorrect when there is region whose RegionLoad cannot be retrieved
This commit is contained in:
parent
ce493642c0
commit
4bb84f7d0c
|
@ -136,16 +136,18 @@ public class SimpleRegionNormalizer implements RegionNormalizer {
|
||||||
", number of regions: " + tableRegions.size());
|
", number of regions: " + tableRegions.size());
|
||||||
|
|
||||||
long totalSizeMb = 0;
|
long totalSizeMb = 0;
|
||||||
|
int acutalRegionCnt = 0;
|
||||||
|
|
||||||
for (int i = 0; i < tableRegions.size(); i++) {
|
for (int i = 0; i < tableRegions.size(); i++) {
|
||||||
HRegionInfo hri = tableRegions.get(i);
|
HRegionInfo hri = tableRegions.get(i);
|
||||||
long regionSize = getRegionSize(hri);
|
long regionSize = getRegionSize(hri);
|
||||||
if (regionSize > 0) {
|
if (regionSize > 0) {
|
||||||
|
acutalRegionCnt++;
|
||||||
totalSizeMb += regionSize;
|
totalSizeMb += regionSize;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
double avgRegionSize = totalSizeMb / (double) tableRegions.size();
|
double avgRegionSize = acutalRegionCnt == 0 ? 0 : totalSizeMb / (double) acutalRegionCnt;
|
||||||
|
|
||||||
LOG.debug("Table " + table + ", total aggregated regions size: " + totalSizeMb);
|
LOG.debug("Table " + table + ", total aggregated regions size: " + totalSizeMb);
|
||||||
LOG.debug("Table " + table + ", average region size: " + avgRegionSize);
|
LOG.debug("Table " + table + ", average region size: " + avgRegionSize);
|
||||||
|
|
Loading…
Reference in New Issue