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()) {