You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/08/08 09:24:23 UTC
[pulsar] 07/11: Fix ConcurrentModificationException when ModularLoadManagerImpl start (#16953)
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 <An...@gmail.com>
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.