-
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
[fix] [admin] setOffloadThreshold response before it's finished #19370
[fix] [admin] setOffloadThreshold response before it's finished #19370
Conversation
/pulsarbot rerun-failure-checks |
@@ -2047,7 +2047,7 @@ protected CompletableFuture<Void> internalSetOffloadThresholdInSecondsAsync(long | |||
|
|||
validateNamespacePolicyOperationAsync(namespaceName, PolicyName.OFFLOAD, PolicyOperation.WRITE) | |||
.thenApply(v -> validatePoliciesReadOnlyAccessAsync()) |
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.
@poorbarcode Thanks for finding the issue and fixing this.
Isn't there a similar bug on the previous line with the validatePoliciesReadOnlyAccessAsync
call?
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.
Ah, you are right. Thanks for helping to check. I have submitted a PR to fix it.
This change is to fix the admin API by adding in the below PR which is not included in branch-2.10. So remove the label release 2.10.4. |
No need to cherry pick to branch-2.11 too. |
Fixes #19366
Motivation
Admin API
setOffloadThreshold
response before it is finished.You can reproduce by
AdminApiOffloadTest.testSetNamespaceOffloadPolicies
, If you appendsleep(1000)
after this line(pulsar/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
Line 468 in 1cd1aef
Modifications
response after it is finishied
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: