This is an automated email from the ASF dual-hosted git repository.
reidchan pushed a commit to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.2 by this push:
new 59fda38 HBASE-22596 [Chore] Separate the execution period between
CompactionChecker and PeriodicMemStoreFlusher
59fda38 is described below
commit 59fda3890c0368eb8f99b030963f0be6665d48eb
Author: Reid Chan <reidc...@apache.org>
AuthorDate: Tue Jun 18 11:09:34 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 57f33cd..8ecd283 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
@@ -355,6 +355,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.
@@ -572,6 +577,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);
@@ -2018,8 +2025,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
