This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch bewaremypower/2.8-pick-15694
in repository https://gitbox.apache.org/repos/asf/pulsar.git
discard 5bb38a8145e [branch-2.8][fix][security] Add timeout of sync methods
and avoid call sync method for AuthoriationService (#15694)
add 3bbb7c7f6d2 [Broker] Expose topic level storage write and read rate
metrics (#16855)
add 3b164f5ac0c Revert "[improve][broker] Avoid reconnection when a
partitioned topic was created concurrently (#16043)"
add 739c45e8075 [fix][Java Client] Fix thread safety issue of
`LastCumulativeAck` (#16072)
add 7a3ed537f38 Fix `messageQueue` release message issue. (#16155)
add b607d09176f [fix][broker] Fix NPE when drop backlog for time limit.
(#16235)
add a97131eeabf [Branch-2.9][Cherry-pick] fix bug: fail to expose managed
ledger client stats to prometheus if bookkeeperClientExposeStatsToPrometheus is
true #16219 (#16343)
add f45985e7bff Increase timeout in
PersistentStreamingDispatcherBlockConsumerTest.testBlockBrokerDispatching
(#12943)
add b06b2ee056a Update/fix Swagger Annotation for param: authoritative
(#16222)
add 688bfa39774 [fix][broker]Fix getInternalStats occasional lack of
LeaderInfo again (#16238)
add c0eef81e6a5 [fix][C++ client] Fix the close of Client might stuck or
return a wrong result (#16285)
add 7f9cd930594 [fix][broker] Fix setManagedLedgerOffloadedReadPriority
not work. (#16436)
add 0dc2cede6c7 [fix][broker] fix No such ledger exception (#16420)
add fbba81446b9 [improve][test] Fix flaky C++ ClientTest.testWrongListener
(#16510)
add 003e1737410 [fix][pulsar-broker] Fix RawReader hasMessageAvailable
returns true when no messages (#16443)
add aa0b3f6cee9 [fix][proxy] Do not preserve host when forwarding admin
requests. (#16342)
add 2d457765121 [fix][broker] Fix stats-internal with option -m cause
active ledger recover then close (#16662)
add cb12e2fd87c [fix][client] Fix ReconsumeLater will hang up if
retryLetterProducer exception (#16655)
add 553b6d7bcf3 [branch-2.8][fix][security] Add timeout of sync methods
and avoid call sync method for AuthoriationService (#15694)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5bb38a8145e)
\
N -- N -- N refs/heads/bewaremypower/2.8-pick-15694 (553b6d7bcf3)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 49 +++--
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 17 ++
.../pulsar/broker/ManagedLedgerClientFactory.java | 5 +-
.../pulsar/broker/admin/v1/PersistentTopics.java | 8 +-
.../broker/admin/v2/NonPersistentTopics.java | 10 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 203 +++++++++++----------
.../pulsar/broker/service/BacklogQuotaManager.java | 4 +
.../pulsar/broker/service/BrokerService.java | 48 +----
.../broker/service/persistent/PersistentTopic.java | 76 ++++----
.../pulsar/broker/stats/prometheus/TopicStats.java | 4 +
.../apache/pulsar/client/impl/RawReaderImpl.java | 3 +
.../pulsar/broker/stats/PrometheusMetricsTest.java | 32 ++++
.../client/api/DispatcherBlockConsumerTest.java | 2 +-
.../apache/pulsar/client/api/RetryTopicTest.java | 60 ++++++
.../apache/pulsar/client/impl/RawReaderTest.java | 52 ++++++
.../common/naming/ServiceConfigurationTest.java | 3 +
pulsar-client-cpp/lib/ClientImpl.cc | 45 +++--
pulsar-client-cpp/lib/ReaderImpl.cc | 21 ++-
pulsar-client-cpp/lib/ReaderImpl.h | 4 +-
pulsar-client-cpp/tests/ClientTest.cc | 34 ++++
.../apache/pulsar/client/impl/ConsumerImpl.java | 8 +-
.../PersistentAcknowledgmentsGroupingTracker.java | 141 +++++++-------
.../pulsar/client/impl/LastCumulativeAckTest.java | 86 +++++++++
.../common/policies/data/OffloadPoliciesImpl.java | 5 +
.../pulsar/proxy/server/ProxyServiceStarter.java | 1 -
.../proxy/server/AuthedAdminProxyHandlerTest.java | 1 -
.../SuperUserAuthedAdminProxyHandlerTest.java | 1 -
.../server/UnauthedAdminProxyHandlerTest.java | 1 -
.../pulsar/sql/presto/PulsarRecordCursor.java | 14 +-
29 files changed, 619 insertions(+), 319 deletions(-)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/LastCumulativeAckTest.java
