From 95f83cb8e242f5d8b9fb55b9d406c3ba54b5cb92 Mon Sep 17 00:00:00 2001 From: haosen chen <99318736+haosenchen@users.noreply.github.com> Date: Sun, 23 Apr 2023 23:20:47 +0800 Subject: [PATCH] HBASE-27807 PressureAwareCompactionThroughputController#tune log the opposite of the actual scenario (#5198) Signed-off-by: Duo Zhang --- .../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()) {