-
Notifications
You must be signed in to change notification settings - Fork 3.7k
fix select broker is none #16316
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
fix select broker is none #16316
Conversation
| getAvailableBrokers(), | ||
| brokerTopicLoadingPredicate); | ||
| broker = placementStrategy.selectBroker(brokerCandidateCache, data, loadData, conf); | ||
| Optional<String> brokerTmp = placementStrategy.selectBroker(brokerCandidateCache, data, loadData, conf); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java:[881] (sizes) LineLength: Line is longer than 120 characters (found 124).
Please fix checkstyle violation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fixed.
|
/pulsarbot run-failure-checks |
|
LGTM |
* fix select broker is none * check style (cherry picked from commit cf4fe17)
* fix select broker is none * check style
* fix select broker is none * check style (cherry picked from commit cf4fe17)
* fix select broker is none * check style
Motivation
In selectBrokerForAssignment, when the broker is selected again, it is not judged whether the selected broker is empty.
Documentation
Check the box below or label this PR directly.
Need to update docs?
doc-required(Your PR needs to update docs and you will update later)
doc-not-needed(Please explain why)
doc(Your PR contains doc changes)
doc-complete(Docs have been already added)