This is an automated email from the ASF dual-hosted git repository.
rgao pushed a change to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 5808edb74d6 [fix][build][branch-3.1] Fix compile issue in test (#22187)
new fee3a335416 [fix] [broker] Expire messages according to ledger close
time to avoid client clock skew (#21940)
new d58d5983da3 [fix][fn] Use unified PackageManagement service to
download packages (#21955)
new 09cb54148c1 [fix][broker]Support setting `autoSkipNonRecoverableData`
dynamically in expiryMon… (#21991)
new 7eec36e743f [fix] [client] Do no retrying for error subscription not
found when disabled allowAutoSubscriptionCreation (#22078)
new c9ecd5221f4 [fix][test] Fix test testAsyncFunctionMaxPending (#22121)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../broker/service/BrokerServiceException.java | 2 +
.../persistent/PersistentMessageExpiryMonitor.java | 46 ++++++++++++++++++++--
.../service/PersistentMessageFinderTest.java | 28 ++++++++++++-
.../service/persistent/PersistentTopicTest.java | 26 ++++++++++++
.../pulsar/client/api/MultiTopicsConsumerTest.java | 32 +++++++++++++++
.../pulsar/client/api/PulsarClientException.java | 17 ++++++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +
.../functions/instance/JavaInstanceTest.java | 11 +++++-
.../functions/worker/rest/api/ComponentImpl.java | 2 +
9 files changed, 159 insertions(+), 7 deletions(-)
