This is an automated email from the ASF dual-hosted git repository.
heesung pushed a change to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 7b32451d013 [improve][broker]Ensure namespace deletion doesn't fail
(#22627)
new 15db04d9aee [fix][broker] Fix Replicated Topic unload bug when
ExtensibleLoadManager is enabled (#22496)
new c59001c9c59 [fix][broker] Immediately tombstone Deleted and Free state
bundles (#22743)
new 8ae5f04a868 [fix][broker] Fix NPE after publishing a tombstone to the
service unit channel (#22859)
new b1ad91dd5e0 [fix][broker] Support advertised listeners when gracefully
transferring topics (ExtensibleLoadManagerImpl only) (#22862)
new 9dba0d56088 [fix][broker] Asynchronously return
brokerRegistry.lookupAsync when checking if broker is
active(ExtensibleLoadManagerImpl only) (#22899)
new 77fd54e6a59 [fix][broker] Update init and shutdown time and other
minor logic (ExtensibleLoadManagerImpl only) (#22930)
new 04d3fd47cfc [fix][broker] Ensure that PulsarService is ready for
serving incoming requests (#22977)
new f77e1553ae3 [fix][broker] Check the broker is available for the SLA
monitor bundle when the ExtensibleLoadManager is enabled (#22485)
new 5b34894f560 [fix][broker] Support lookup options for extensible load
manager (#22487)
The 9 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 | 145 ++++++++-----
.../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 | 45 +++-
.../service/nonpersistent/NonPersistentTopic.java | 3 +-
.../broker/service/persistent/PersistentTopic.java | 3 +-
.../org/apache/pulsar/broker/web/WebService.java | 50 +++++
.../AntiAffinityNamespaceGroupExtensionTest.java | 4 +-
.../ExtensibleLoadManagerImplBaseTest.java | 18 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 193 +++++++++++++++--
...LoadManagerImplWithAdvertisedListenersTest.java | 92 +++++++++
...dManagerImplWithTransactionCoordinatorTest.java | 4 +-
.../channel/ServiceUnitStateChannelTest.java | 105 +++++++---
.../extensions/data/BrokerLookupDataTest.java | 32 ++-
.../extensions/manager/SplitManagerTest.java | 27 +--
.../extensions/manager/UnloadManagerTest.java | 25 ++-
.../protocol/PulsarClientBasedHandlerTest.java | 3 +-
.../broker/service/ReplicatorGlobalNSTest.java | 16 ++
.../pulsar/broker/service/ReplicatorTestBase.java | 19 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 3 +-
30 files changed, 871 insertions(+), 307 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImplWithAdvertisedListenersTest.java
