This is an automated email from the ASF dual-hosted git repository.
heesung pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 13806d7430c [fix] [conf] fix typo for TransferShedder. (#22757)
13806d7430c is described below
commit 13806d7430c3dc359f416b82b5ae309f9d558057
Author: Wenzhi Feng <[email protected]>
AuthorDate: Wed May 22 13:41:46 2024 +0800
[fix] [conf] fix typo for TransferShedder. (#22757)
---
conf/broker.conf | 12 ++++++------
.../java/org/apache/pulsar/broker/ServiceConfiguration.java | 12 ++++++------
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/conf/broker.conf b/conf/broker.conf
index 2a9641b5b90..f1ec8e7a09f 100644
--- a/conf/broker.conf
+++ b/conf/broker.conf
@@ -1429,14 +1429,14 @@ loadBalancerDebugModeEnabled=false
# (100% resource usage is 1.0 load).
# The shedder logic tries to distribute bundle load across brokers to meet
this target std.
# The smaller value will incur load balancing more frequently.
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalancerBrokerLoadTargetStd=0.25
# Threshold to the consecutive count of fulfilled shedding(unload) conditions.
# If the unload scheduler consecutively finds bundles that meet unload
conditions
# many times bigger than this threshold, the scheduler will shed the bundles.
# The bigger value will incur less bundle unloading/transfers.
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalancerSheddingConditionHitCountThreshold=3
# Option to enable the bundle transfer mode when distributing bundle loads.
@@ -1444,18 +1444,18 @@ loadBalancerSheddingConditionHitCountThreshold=3
# -- pre-assigns the destination broker upon unloading).
# Off: unload bundles from overloaded brokers
# -- post-assigns the destination broker upon lookups).
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalancerTransferEnabled=true
# Maximum number of brokers to unload bundle load for each unloading cycle.
# The bigger value will incur more unloading/transfers for each unloading
cycle.
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalancerMaxNumberOfBrokerSheddingPerCycle=3
# Delay (in seconds) to the next unloading cycle after unloading.
# The logic tries to give enough time for brokers to recompute load after
unloading.
# The bigger value will delay the next unloading cycle longer.
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalanceSheddingDelayInSeconds=180
# Broker load data time to live (TTL in seconds).
@@ -1463,7 +1463,7 @@ loadBalanceSheddingDelayInSeconds=180
# and those brokers will be ignored in the load computation.
# When tuning this value, please consider
loadBalancerReportUpdateMaxIntervalMinutes.
#The current default is loadBalancerReportUpdateMaxIntervalMinutes * 2.
-# (only used in load balancer extension TransferSheddeer)
+# (only used in load balancer extension TransferShedder)
loadBalancerBrokerLoadDataTTLInSeconds=1800
# Max number of bundles in bundle load report from each broker.
diff --git
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
index 6f03bef3054..c18ffe4bc18 100644
---
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
+++
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
@@ -2596,7 +2596,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
+ "(100% resource usage is 1.0 load). "
+ "The shedder logic tries to distribute bundle load
across brokers to meet this target std. "
+ "The smaller value will incur load balancing more
frequently. "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private double loadBalancerBrokerLoadTargetStd = 0.25;
@@ -2607,7 +2607,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
+ "If the unload scheduler consecutively finds bundles
that meet unload conditions "
+ "many times bigger than this threshold, the scheduler
will shed the bundles. "
+ "The bigger value will incur less bundle
unloading/transfers. "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private int loadBalancerSheddingConditionHitCountThreshold = 3;
@@ -2619,7 +2619,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
+ "-- pre-assigns the destination broker upon unloading). "
+ "Off: unload bundles from overloaded brokers "
+ "-- post-assigns the destination broker upon lookups). "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private boolean loadBalancerTransferEnabled = true;
@@ -2628,7 +2628,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
dynamic = true,
doc = "Maximum number of brokers to unload bundle load for each
unloading cycle. "
+ "The bigger value will incur more unloading/transfers
for each unloading cycle. "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private int loadBalancerMaxNumberOfBrokerSheddingPerCycle = 3;
@@ -2638,7 +2638,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
doc = "Delay (in seconds) to the next unloading cycle after
unloading. "
+ "The logic tries to give enough time for brokers to
recompute load after unloading. "
+ "The bigger value will delay the next unloading cycle
longer. "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private long loadBalanceSheddingDelayInSeconds = 180;
@@ -2651,7 +2651,7 @@ public class ServiceConfiguration implements
PulsarConfiguration {
+ "When tuning this value, please consider
loadBalancerReportUpdateMaxIntervalMinutes. "
+ "The current default value is
loadBalancerReportUpdateMaxIntervalMinutes * 120, reflecting "
+ "twice the duration in seconds. "
- + "(only used in load balancer extension TransferSheddeer)"
+ + "(only used in load balancer extension TransferShedder)"
)
private long loadBalancerBrokerLoadDataTTLInSeconds = 1800;
