From 130a463929672ffc5f0e7e7cc1c46bd094a89e85 Mon Sep 17 00:00:00 2001 From: chenhaosen 00620237 Date: Fri, 21 Apr 2023 16:28:39 +0800 Subject: [PATCH] HBASE-27807 PressureAwareCompactionThroughputController#tune log the opposite of the actual scenario Correct the condition of the if statement --- .../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 4ccabde07f..fe19be32c4 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()) { -- 2.32.0.windows.2