This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from eb502e4f61e [improve][broker] Fix replicated subscriptions race
condition with mark delete update and snapshot completion (#16651)
new 4149e58ed3e [fix][sec] Bump at.yawk.lz4:lz4-java from 1.9.0 to 1.10.1
in /pulsar-common (#25045)
new c6edce57b47 [fix][cli] Fix some pulsar-admin topicPolicies commands
exiting before async operations complete (#25051)
new bab7a376e8d [fix][cli] Fix output of --print-metadata in cli consume
(#25056)
new 595fe3a1145 [improve][build] Upgrade errorprone to 2.45.0 version
(#25054)
new 34cbdaddcd7 [fix][broker] Fix various error-prone detected errors
mainly in logging and String.format parameters (#25059)
new e6c540001ac [fix][admin] Refactor bookie affinity group sync
operations to async in rest api (#25050)
new 9f56bd6dac1 [fix][broker] Force EnsemblePolicies to resolve network
location after rackInfoMap is updated due to changes in /ledgers/available
znode (#25067)
new d7da8623e92 [improve][broker] Improve replicated subscription snapshot
cache so that subscriptions can be replicated when mark delete position update
is not frequent (#25044)
new f32236ff7c3 [fix][broker] PIP-442: Fix race condition in async
semaphore permit updates that causes memory limits to become ineffective
(#25066)
new b74c4cb8ae7 [fix][client] Fix invalid parameter type passed to Map.get
in TopicsImpl.getListAsync method (#25069)
new 3247ea58653 [improve][broker] Use atomic counter for ongoing
transaction count (#25053)
The 11 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:
conf/broker.conf | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 2 +-
distribution/shell/src/assemble/LICENSE.bin.txt | 2 +-
pom.xml | 8 +-
.../rackawareness/BookieRackAffinityMapping.java | 26 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 2 +-
.../broker/resources/LocalPoliciesResources.java | 5 +
.../BookieRackAffinityMappingTest.java | 143 +++++++--
.../pulsar/broker/admin/impl/NamespacesBase.java | 77 +++--
.../apache/pulsar/broker/admin/v1/Namespaces.java | 41 ++-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 43 ++-
.../extensions/scheduler/SplitScheduler.java | 2 +-
.../DefaultNamespaceBundleSplitStrategyImpl.java | 2 +-
.../service/PulsarMetadataEventSynchronizer.java | 8 +-
.../apache/pulsar/broker/service/ServerCnx.java | 4 +-
.../persistent/GeoPersistentReplicator.java | 2 +-
.../service/persistent/PersistentSubscription.java | 6 +-
.../broker/service/persistent/PersistentTopic.java | 5 +-
.../ReplicatedSubscriptionSnapshotCache.java | 354 +++++++++++++++++++--
.../ReplicatedSubscriptionsController.java | 18 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 3 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 27 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 34 ++
.../pulsar/broker/admin/NamespacesV2Test.java | 45 ++-
.../pulsar/broker/service/PersistentTopicTest.java | 2 +
.../TransactionMetadataStoreServiceTest.java | 47 ++-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 241 +++++++++++++-
...nConsumerBackPressureMultipleConsumersTest.java | 136 ++++----
.../pulsar/client/admin/internal/TopicsImpl.java | 2 +-
.../apache/pulsar/admin/cli/CmdTopicPolicies.java | 9 +-
.../pulsar/client/cli/AbstractCmdConsume.java | 4 +-
pulsar-common/pom.xml | 2 +-
.../semaphore/AsyncDualMemoryLimiterImpl.java | 4 +-
.../common/semaphore/AsyncSemaphoreImpl.java | 68 ++--
.../semaphore/AsyncDualMemoryLimiterImplTest.java | 24 ++
.../pulsar/proxy/server/LookupProxyHandler.java | 7 +-
...nConsumerBackPressureMultipleConsumersTest.java | 20 ++
.../impl/MLTransactionMetadataStore.java | 27 +-
.../coordinator/impl/MLTransactionLogImplTest.java | 2 +-
39 files changed, 1150 insertions(+), 306 deletions(-)
