-
Notifications
You must be signed in to change notification settings - Fork 3.6k
[fix][broker] fix ExtensibleLoadManager to override the ownerships concurrently without blocking load manager thread #24156
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
Conversation
…ncurrently without blocking load manager thread
@heesung-sn Please add the following content to your PR description and select a checkbox:
|
...ava/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java
Outdated
Show resolved
Hide resolved
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.
Left some review comments
...ava/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java
Outdated
Show resolved
Hide resolved
...ava/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java
Show resolved
Hide resolved
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.
LGTM
…ncurrently without blocking load manager thread (apache#24156)
…ncurrently without blocking load manager thread (apache#24156) (cherry picked from commit 066a20c) (cherry picked from commit 970df5f)
…ncurrently without blocking load manager thread (apache#24156) (cherry picked from commit 066a20c) (cherry picked from commit 970df5f)
…ncurrently without blocking load manager thread (apache#24156) (cherry picked from commit 066a20c) (cherry picked from commit 970df5f)
…ncurrently without blocking load manager thread (apache#24156) (cherry picked from commit 066a20c) (cherry picked from commit 970df5f)
…ncurrently without blocking load manager thread (apache#24156) (cherry picked from commit 066a20c) (cherry picked from commit 970df5f)
This fix has this bug. please pull this PR as well. #24196 |
Motivation
Currently, ExtensibleLoadManager overrides orphan ownerships one by one while holding the monitor lock. This can delay the synchronized serviceUnitStateChannel.started() call(required for SystemTopicPoliciesService.getTopicPoliciesAsync and others) when the metadata service is slow(is overloaded).
Modifications
loadBalancerServiceUnitStateMaxConcurrentOverrides
).TopBundlesLoadData is empty
log under debug flagVerifying this change
Does this pull request potentially affect one of the following parts:
If the box was checked, please highlight the changes
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: