This is an automated email from the ASF dual-hosted git repository.
heesung pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from ca45181f4db [improve][broker]Ensure namespace deletion doesn't fail
(#22627)
new 4c0029f4be7 [fix][broker] Immediately tombstone Deleted and Free state
bundles (#22743)
new 69f671af61b [fix][broker] Fix NPE after publishing a tombstone to the
service unit channel (#22859)
new bfd45e1d066 [fix][broker] Support advertised listeners when gracefully
transferring topics (ExtensibleLoadManagerImpl only) (#22862)
new 8b626bdef6e [fix][broker] Asynchronously return
brokerRegistry.lookupAsync when checking if broker is
active(ExtensibleLoadManagerImpl only) (#22899)
new f77e05b0e55 [fix][broker] Update init and shutdown time and other
minor logic (ExtensibleLoadManagerImpl only) (#22930)
new 7d81ee9d7de [fix][broker] Ensure that PulsarService is ready for
serving incoming requests (#22977)
The 6 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 ++-
.../extensions/ExtensibleLoadManagerImpl.java | 140 ++++++++++++---------
.../channel/ServiceUnitStateChannelImpl.java | 128 +++++++++++--------
.../extensions/manager/SplitManager.java | 2 +-
.../extensions/manager/UnloadManager.java | 14 ++-
.../store/TableViewLoadDataStoreImpl.java | 12 +-
.../pulsar/broker/namespace/NamespaceService.java | 10 +-
.../broker/service/PulsarChannelInitializer.java | 7 +-
.../apache/pulsar/broker/service/ServerCnx.java | 45 +++++--
.../org/apache/pulsar/broker/web/WebService.java | 50 ++++++++
.../ExtensibleLoadManagerImplBaseTest.java | 15 ++-
.../extensions/ExtensibleLoadManagerImplTest.java | 98 +++++++++++++--
...LoadManagerImplWithAdvertisedListenersTest.java | 98 +++++++++++++++
...dManagerImplWithTransactionCoordinatorTest.java | 4 +-
.../channel/ServiceUnitStateChannelTest.java | 91 ++++++++++----
.../extensions/manager/SplitManagerTest.java | 27 +---
.../extensions/manager/UnloadManagerTest.java | 25 +++-
.../protocol/PulsarClientBasedHandlerTest.java | 3 +-
19 files changed, 587 insertions(+), 202 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImplWithAdvertisedListenersTest.java
