Skip to content

Commit

Permalink
[fix] [conf] fix typo for TransferShedder. (apache#22757)
Browse files Browse the repository at this point in the history
  • Loading branch information
thetumbled authored May 22, 2024
1 parent adad1fb commit 13806d7
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
12 changes: 6 additions & 6 deletions conf/broker.conf
Original file line number Diff line number Diff line change
Expand Up @@ -1429,41 +1429,41 @@ 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.
# On: transfer bundles from overloaded brokers to underloaded
# -- 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).
# The logic tries to avoid (possibly unavailable) brokers with out-dated load data,
# 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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2596,7 +2596,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
+ "(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;

Expand All @@ -2607,7 +2607,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
+ "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;

Expand All @@ -2619,7 +2619,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
+ "-- 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;

Expand All @@ -2628,7 +2628,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
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;

Expand All @@ -2638,7 +2638,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
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;

Expand All @@ -2651,7 +2651,7 @@ The max allowed delay for delayed delivery (in milliseconds). If the broker rece
+ "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;

Expand Down

0 comments on commit 13806d7

Please sign in to comment.