Skip to content
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

Fixed casting in ZooKeeperCache.getDataIfPresent() #6313

Merged
merged 2 commits into from
Feb 12, 2020

Conversation

merlimat
Copy link
Contributor

Motivation

There was a casting error in ZooKeeperCache.getDataIfPresent() which is being called when checking the policies for the publish rate limiter.

This result in the rate limiter to not get applied. The error printed is:

10:07:50.378 [bookkeeper-ml-workers-OrderedExecutor-1-0] WARN org.apache.pulsar.broker.service.AbstractTopic - [persistent://public/default/testDelayedMessages-1581070070308] Error getting policies java.util.concurrent.CompletableFuture cannot be cast to org.apache.pulsar.common.policies.data.Policies and publish throttling will be disabled

@merlimat merlimat added type/bug The PR fixed a bug or issue reported a bug release/2.5.1 labels Feb 12, 2020
@merlimat merlimat added this to the 2.6.0 milestone Feb 12, 2020
@merlimat merlimat self-assigned this Feb 12, 2020
@merlimat merlimat merged commit 7cade48 into apache:master Feb 12, 2020
@merlimat merlimat deleted the fix-zk-cache-cast branch February 14, 2020 19:19
tuteng pushed a commit to AmateurEvents/pulsar that referenced this pull request Feb 23, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check
tuteng pushed a commit to AmateurEvents/pulsar that referenced this pull request Mar 21, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check

(cherry picked from commit 7cade48)
tuteng pushed a commit that referenced this pull request Apr 6, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check

(cherry picked from commit 7cade48)
tuteng pushed a commit that referenced this pull request Apr 13, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check

(cherry picked from commit 7cade48)
jerrypeng pushed a commit to jerrypeng/incubator-pulsar that referenced this pull request May 15, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check
jiazhai pushed a commit to jiazhai/pulsar that referenced this pull request May 18, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check

(cherry picked from commit 7cade48)
huangdx0726 pushed a commit to huangdx0726/pulsar that referenced this pull request Aug 24, 2020
* Fixed casting in ZooKeeperCache.getDataIfPresent()

* Missed null check
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
release/2.5.1 type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants