From 13806d7430c3dc359f416b82b5ae309f9d558057 Mon Sep 17 00:00:00 2001 From: Wenzhi Feng <52550727+thetumbled@users.noreply.github.com> Date: Wed, 22 May 2024 13:41:46 +0800 Subject: [PATCH] [fix] [conf] fix typo for TransferShedder. (#22757) --- conf/broker.conf | 12 ++++++------ .../apache/pulsar/broker/ServiceConfiguration.java | 12 ++++++------ 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/conf/broker.conf b/conf/broker.conf index 2a9641b5b90b8..f1ec8e7a09f89 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 6f03bef30548e..c18ffe4bc1886 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 @@ 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; @@ -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; @@ -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; @@ -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; @@ -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; @@ -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;