This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 51d564690df098d25d446a035f494e1b3032a362 Author: Xiaoyu Hou <[email protected]> AuthorDate: Mon Aug 8 10:08:57 2022 +0800 Fix ConcurrentModificationException when ModularLoadManagerImpl start (#16953) --- .../apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java index 8c0df048de7..9444737fb79 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java @@ -197,7 +197,7 @@ public class ModularLoadManagerImpl implements ModularLoadManager { private long unloadBundleCount = 0; private final Lock lock = new ReentrantLock(); - private Set<String> knownBrokers = new HashSet<>(); + private Set<String> knownBrokers = ConcurrentHashMap.newKeySet(); /** * Initializes fields which do not depend on PulsarService. initialize(PulsarService) should subsequently be called.
