diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 24bb09a..25fe6a4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -1362,10 +1362,11 @@ public class HRegionServer extends HasThread implements class PeriodicMemstoreFlusher extends Chore { final HRegionServer server; - final static int RANGE_OF_DELAY = 20000; //millisec - final static int MIN_DELAY_TIME = 3000; //millisec + final static int RANGE_OF_DELAY = 60000; //millisec + final static int MIN_DELAY_TIME = 10000; //millisec public PeriodicMemstoreFlusher(int cacheFlushInterval, final HRegionServer server) { - super(server.getServerName() + "-MemstoreFlusherChore", cacheFlushInterval, server); + super(server.getServerName() + "-MemstoreFlusherChore", Math.max(RANGE_OF_DELAY + + MIN_DELAY_TIME, cacheFlushInterval), server); this.server = server; }