This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 87674c4b8ec Bump version to next snapshot version
new ee4e630578b [improve][test] Add solution to PulsarMockBookKeeper for
intercepting reads (#23875)
new 75c9ed70408 [fix][test] Fix quiet time implementation in
BrokerTestUtil.receiveMessages (#23876)
new a5992e77861 [fix][broker] PIP-379 Key_Shared implementation race
condition causing out-of-order message delivery (#23874)
new c5df52b7314 [improve][ci] Increase Maven max heap size to 2048M and
tune GCLockerRetryAllocationCount (#23883)
new b21aa768099 [improve][broker] Support values up to 2^32 in
ConcurrentBitmapSortedLongPairSet (#23878)
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:
.github/workflows/ci-owasp-dependency-check.yaml | 2 +-
.github/workflows/pulsar-ci-flaky.yaml | 2 +-
.github/workflows/pulsar-ci.yaml | 2 +-
.../PersistentDispatcherMultipleConsumers.java | 3 +
...istentStickyKeyDispatcherMultipleConsumers.java | 57 +++-
.../utils/ConcurrentBitmapSortedLongPairSet.java | 14 +-
.../org/apache/pulsar/broker/BrokerTestUtil.java | 41 ++-
.../apache/pulsar/broker/BrokerTestUtilTest.java | 115 +++++++
...ySharedSubscriptionDisabledBrokerCacheTest.java | 348 +++++++++++++++++++++
.../ConcurrentBitmapSortedLongPairSetTest.java | 30 +-
pulsar-broker/src/test/resources/log4j2.xml | 8 +-
.../bookkeeper/client/PulsarMockBookKeeper.java | 8 +-
.../bookkeeper/client/PulsarMockLedgerHandle.java | 2 +-
.../bookkeeper/client/PulsarMockReadHandle.java | 31 +-
.../client/PulsarMockReadHandleInterceptor.java | 27 +-
15 files changed, 623 insertions(+), 67 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/BrokerTestUtilTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionDisabledBrokerCacheTest.java
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/reporter/LoadDataReporter.java
=>
testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockReadHandleInterceptor.java
(52%)