-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
[improve][broker] PIP-192: Implement broker version filter for new load manager #19023
[improve][broker] PIP-192: Implement broker version filter for new load manager #19023
Conversation
e445817
to
73b850d
Compare
...rc/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/BrokerVersionFilter.java
Outdated
Show resolved
Hide resolved
...rc/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/BrokerVersionFilter.java
Outdated
Show resolved
Hide resolved
log.info("Latest broker version found was [{}]", latestVersion); | ||
} catch (Exception ex) { | ||
log.warn("Disabling PreferLaterVersions feature; reason: " + ex.getMessage()); | ||
throw new BrokerFilterBadVersionException("Cannot determine newest broker version: " + ex.getMessage()); |
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.
If an exception is thrown here, do we skip this filter?
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.
Yes, we should handle the exception when using the filter.
73b850d
to
a40e190
Compare
/pulsarbot run-failure-checks |
Codecov Report
@@ Coverage Diff @@
## master #19023 +/- ##
=============================================
- Coverage 47.74% 35.60% -12.14%
+ Complexity 10623 8272 -2351
=============================================
Files 703 772 +69
Lines 68828 74282 +5454
Branches 7381 7994 +613
=============================================
- Hits 32861 26449 -6412
- Misses 32307 44318 +12011
+ Partials 3660 3515 -145
Flags with carried forward coverage won't be shown. Click here to find out more.
|
a40e190
to
f670d64
Compare
Motivation
We will start raising PRs to implement PIP-192, #16691
Modifications
This PR Added
BrokerVersionFilter
to the load balancer extensions and its unit test.For the pip-192 project, this
BrokerVersionFilter
org.apache.pulsar.broker.loadbalance.impl.BrokerVersionFilter
.Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: Demogorgon314#9