Index: src/main/java/org/apache/hadoop/hbase/regionserver/IncreasingToUpperBoundRegionSplitPolicy.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/IncreasingToUpperBoundRegionSplitPolicy.java (revision 1567461) +++ src/main/java/org/apache/hadoop/hbase/regionserver/IncreasingToUpperBoundRegionSplitPolicy.java (working copy) @@ -41,18 +41,22 @@ extends ConstantSizeRegionSplitPolicy { static final Log LOG = LogFactory.getLog(IncreasingToUpperBoundRegionSplitPolicy.class); - private long flushSize; + private long initialSize; @Override protected void configureForRegion(HRegion region) { super.configureForRegion(region); Configuration conf = getConf(); + this.initialSize = conf.getLong("hbase.increasing.policy.initial.size", -1); + if (this.initialSize > 0) { + return; + } HTableDescriptor desc = region.getTableDesc(); if (desc != null) { - this.flushSize = desc.getMemStoreFlushSize(); + this.initialSize = desc.getMemStoreFlushSize(); } - if (this.flushSize <= 0) { - this.flushSize = conf.getLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, + if (this.initialSize <= 0) { + this.initialSize = conf.getLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, HTableDescriptor.DEFAULT_MEMSTORE_FLUSH_SIZE); } } @@ -93,7 +97,7 @@ long getSizeToCheck(final int tableRegionsCount) { return tableRegionsCount == 0? getDesiredMaxFileSize(): Math.min(getDesiredMaxFileSize(), - this.flushSize * (tableRegionsCount * tableRegionsCount)); + this.initialSize * (tableRegionsCount * tableRegionsCount)); } /**