[hbase] branch branch-1 updated: HBASE-22596 [Chore] Separate the execution period between CompactionChecker and PeriodicMemStoreFlusher

[reidchan]

This is an automated email from the ASF dual-hosted git repository.

reidchan pushed a commit to branch branch-1
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-1 by this push:
     new be9f0dd  HBASE-22596 [Chore] Separate the execution period between 
CompactionChecker and PeriodicMemStoreFlusher
be9f0dd is described below

commit be9f0dd58833827a7ce038f66343dd00236dc559
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 ab76e90..573a64a 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
@@ -341,6 +341,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.
@@ -548,6 +553,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);
@@ -911,8 +918,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