lifepuzzlefun commented on code in PR #20620:
URL: https://github.com/apache/pulsar/pull/20620#discussion_r1236208743
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java:
##########
@@ -603,6 +592,16 @@ private void updateBundleData() {
LoadManagerShared.fillNamespaceToBundlesMap(preallocatedBundleData.keySet(),
namespaceToBundleRange);
}
}
+
Review Comment:
Sure.
If we need to figure out which bundle is not active, we should get cluster
wide all bundle data, right ? To get all cluster wide bundle data, we need
iterate all brokerData to collect this.
Current we only iterate the first brokerData and check active bundles. so
the all the bundleData which is not owned by the first broker will be cleaned
at the first broker check.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
