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 <[email protected]>
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 <[email protected]>
Signed-off-by: Xu Cang <[email protected]>
---
.../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
