Fix ConcurrentModificationException when ModularLoadManagerImpl start
@@ -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.
