This is an automated email from the ASF dual-hosted git repository.
heesung pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 22bfe2704fd [improve][broker]Ensure namespace deletion doesn't fail
(#22627)
new 2557db63d48 [fix][broker] Fix Replicated Topic unload bug when
ExtensibleLoadManager is enabled (#22496)
new 44f2e98bb2e [fix][broker] Immediately tombstone Deleted and Free state
bundles (#22743)
new 9ffbffc113b [fix][broker] Fix NPE after publishing a tombstone to the
service unit channel (#22859)
new 9ab3f38763c [fix][broker] Asynchronously return
brokerRegistry.lookupAsync when checking if broker is
active(ExtensibleLoadManagerImpl only) (#22899)
new d9c51322ce5 [fix][broker] Update init and shutdown time and other
minor logic (ExtensibleLoadManagerImpl only) (#22930)
new 1a7eb540fc0 [fix][broker] Ensure that PulsarService is ready for
serving incoming requests (#22977)
new f623be8a158 [fix][broker] Check the broker is available for the SLA
monitor bundle when the ExtensibleLoadManager is enabled (#22485)
new 2b84dffe3fe [fix][broker] Support lookup options for extensible load
manager (#22487)
The 8 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:
.../apache/pulsar/PulsarClusterMetadataSetup.java | 4 +-
.../org/apache/pulsar/broker/PulsarService.java | 16 +-
.../pulsar/broker/loadbalance/LoadManager.java | 3 +-
.../extensions/ExtensibleLoadManager.java | 5 +-
.../extensions/ExtensibleLoadManagerImpl.java | 230 +++++++++++----------
.../extensions/ExtensibleLoadManagerWrapper.java | 15 +-
.../channel/ServiceUnitStateChannelImpl.java | 141 ++++++++-----
.../extensions/data/BrokerLookupData.java | 17 +-
.../extensions/manager/SplitManager.java | 2 +-
.../extensions/manager/UnloadManager.java | 14 +-
.../store/TableViewLoadDataStoreImpl.java | 12 +-
.../pulsar/broker/namespace/NamespaceService.java | 66 ++++--
.../broker/service/PulsarChannelInitializer.java | 7 +-
.../apache/pulsar/broker/service/ServerCnx.java | 4 +
.../service/nonpersistent/NonPersistentTopic.java | 4 +-
.../broker/service/persistent/PersistentTopic.java | 3 +-
.../org/apache/pulsar/broker/web/WebService.java | 53 ++++-
.../AntiAffinityNamespaceGroupExtensionTest.java | 4 +-
.../ExtensibleLoadManagerImplBaseTest.java | 4 +
.../extensions/ExtensibleLoadManagerImplTest.java | 188 ++++++++++++++---
.../channel/ServiceUnitStateChannelTest.java | 105 +++++++---
.../extensions/data/BrokerLookupDataTest.java | 48 ++++-
.../extensions/manager/SplitManagerTest.java | 27 +--
.../extensions/manager/UnloadManagerTest.java | 25 ++-
.../broker/service/ReplicatorGlobalNSTest.java | 7 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 3 +-
26 files changed, 698 insertions(+), 309 deletions(-)
