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

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


The following commit(s) were added to refs/heads/branch-2.4 by this push:
     new 0e224b1ef6d HBASE-27807 
PressureAwareCompactionThroughputController#tune log the opposite of the actual 
scenario (#5198)
0e224b1ef6d is described below

commit 0e224b1ef6d55d45441b0848ed15ffb95fc8ec06
Author: haosen chen <99318736+haosenc...@users.noreply.github.com>
AuthorDate: Sun Apr 23 23:20:47 2023 +0800

    HBASE-27807 PressureAwareCompactionThroughputController#tune log the 
opposite of the actual scenario (#5198)
    
    Signed-off-by: Duo Zhang <zhang...@apache.org>
    (cherry picked from commit 95f83cb8e242f5d8b9fb55b9d406c3ba54b5cb92)
---
 .../throttle/PressureAwareCompactionThroughputController.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 4ccabde07f1..fe19be32c4d 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
@@ -99,7 +99,7 @@ public class PressureAwareCompactionThroughputController 
extends PressureAwareTh
         + (maxThroughputUpperBound - maxThroughputLowerBound) * 
compactionPressure;
     }
     if (LOG.isDebugEnabled()) {
-      if (Math.abs(maxThroughputToSet - getMaxThroughput()) < .0000001) {
+      if (Math.abs(maxThroughputToSet - getMaxThroughput()) >= .0000001) {
         LOG.debug("CompactionPressure is " + compactionPressure + ", tune 
throughput to "
           + throughputDesc(maxThroughputToSet));
       } else if (LOG.isTraceEnabled()) {

Reply via email to