Skip to content

Commit

Permalink
Fix log in pulsar/pulsar-broker/src/main/java/org/apache/pulsar/broke…
Browse files Browse the repository at this point in the history
…r/loadbalance/impl/ThresholdShedder.java (apache#12435)
  • Loading branch information
lordcheng10 authored Oct 22, 2021
1 parent 34f237b commit cc3bba3
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ public Multimap<String, String> findBundlesForUnloading(final LoadData loadData,
log.info(
"Attempting to shed load on {}, which has max resource usage above avgUsage and threshold {}%"
+ " > {}% + {}% -- Offloading at least {} MByte/s of traffic, left throughput {} MByte/s",
broker, currentUsage, avgUsage, threshold, minimumThroughputToOffload / MB,
broker, 100 * currentUsage, 100 * avgUsage, 100 * threshold, minimumThroughputToOffload / MB,
(brokerCurrentThroughput - minimumThroughputToOffload) / MB);

MutableDouble trafficMarkedToOffload = new MutableDouble(0);
Expand Down

0 comments on commit cc3bba3

Please sign in to comment.