This is an automated email from the ASF dual-hosted git repository. reidchan pushed a commit to branch branch-1.4 in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-1.4 by this push: new 0bc7be7 HBASE-22596 [Chore] Separate the execution period between CompactionChecker and PeriodicMemStoreFlusher 0bc7be7 is described below commit 0bc7be7ab4bb519901990779b1987536711bea3b Author: Reid Chan <reidc...@apache.org> AuthorDate: Thu Jun 20 10:49:11 2019 +0800 HBASE-22596 [Chore] Separate the execution period between CompactionChecker and PeriodicMemStoreFlusher Signed-off-by: Zach York <zy...@apache.org> Signed-off-by: Xu Cang <xuc...@apache.org> --- .../org/apache/hadoop/hbase/regionserver/HRegionServer.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) 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 f26661b..af0c680 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 @@ -330,6 +330,11 @@ public class HRegionServer extends HasThread implements protected final int threadWakeFrequency; protected final int msgInterval; + private static final String PERIOD_COMPACTION = "hbase.regionserver.compaction.check.period"; + private final int compactionCheckFrequency; + private static final String PERIOD_FLUSH = "hbase.regionserver.flush.check.period"; + private final int flushCheckFrequency; + protected final int numRegionsToReport; // Stub to do region server status calls against the master. @@ -537,6 +542,8 @@ public class HRegionServer extends HasThread implements this.numRetries = this.conf.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER); this.threadWakeFrequency = conf.getInt(HConstants.THREAD_WAKE_FREQUENCY, 10 * 1000); + this.compactionCheckFrequency = conf.getInt(PERIOD_COMPACTION, this.threadWakeFrequency); + this.flushCheckFrequency = conf.getInt(PERIOD_FLUSH, this.threadWakeFrequency); this.msgInterval = conf.getInt("hbase.regionserver.msginterval", 3 * 1000); this.sleeper = new Sleeper(this.msgInterval, this); @@ -900,8 +907,8 @@ public class HRegionServer extends HasThread implements // Background thread to check for compactions; needed if region has not gotten updates // in a while. It will take care of not checking too frequently on store-by-store basis. - this.compactionChecker = new CompactionChecker(this, this.threadWakeFrequency, this); - this.periodicFlusher = new PeriodicMemstoreFlusher(this.threadWakeFrequency, this); + this.compactionChecker = new CompactionChecker(this, this.compactionCheckFrequency, this); + this.periodicFlusher = new PeriodicMemstoreFlusher(this.flushCheckFrequency, this); this.leases = new Leases(this.threadWakeFrequency); // Create the thread to clean the moved regions list