You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2019/05/07 18:28:13 UTC

[hbase] branch branch-1 updated: HBASE-21777 Only log compaction pressure throughput when changed or traced

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

liyu 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 fbd53bf  HBASE-21777 Only log compaction pressure throughput when changed or traced
fbd53bf is described below

commit fbd53bfefb08e65d4118009baa85b4bde43e731d
Author: Tak Lon (Stephen) Wu <wu...@amazon.com>
AuthorDate: Tue May 7 11:28:08 2019 -0700

    HBASE-21777 Only log compaction pressure throughput when changed or traced
---
 .../throttle/PressureAwareCompactionThroughputController.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/throttle/PressureAwareCompactionThroughputController.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/throttle/PressureAwareCompactionThroughputController.java
index c0d3b74..7df07bb 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/throttle/PressureAwareCompactionThroughputController.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/throttle/PressureAwareCompactionThroughputController.java
@@ -100,8 +100,13 @@ public class PressureAwareCompactionThroughputController extends PressureAwareTh
               * compactionPressure;
     }
     if (LOG.isDebugEnabled()) {
-      LOG.debug("compactionPressure is " + compactionPressure + ", tune compaction throughput to "
-          + throughputDesc(maxThroughputToSet));
+      if (maxThroughputToSet != getMaxThroughput()) {
+        LOG.debug("CompactionPressure is " + compactionPressure + ", tune throughput to "
+            + throughputDesc(maxThroughputToSet));
+      } else if (LOG.isTraceEnabled()) {
+        LOG.trace("CompactionPressure is " + compactionPressure + ", keep throughput throttling to "
+            + throughputDesc(maxThroughputToSet));
+      }
     }
     this.setMaxThroughput(maxThroughputToSet);
   }