From eae4da9d500ceac00d3f15dd80bf502bb197627f Mon Sep 17 00:00:00 2001 From: haosen chen Date: Sat, 22 Apr 2023 20:21:56 +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 4ccabde07f1d..fe19be32c4d7 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 @@ private void tune(double compactionPressure) { + (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()) {