This is an automated email from the ASF dual-hosted git repository.
yubiao pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from bfd41534087 [fix] [ml] Mark delete stuck due to switching cursor
ledger fails (#22662)
new 670aff0d0b4 [fix] [broker] Part-1: Replicator can not created
successfully due to an orphan replicator in the previous topic owner (#21946)
new 076b55e73d5 [improve] [broker] Create partitioned topics automatically
when enable topic level replication (#22537)
new 6038bbfe42e [fix] [broker] Part-2: Replicator can not created
successfully due to an orphan replicator in the previous topic owner (#21948)
new 620fe9be239 [fix][broker] One topic can be closed multiple times
concurrently (#17524)
new 9242f333d9c [fix] [test] Fix flaky test ReplicatorTest (#22594)
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:
.../apache/pulsar/broker/admin/AdminResource.java | 104 ++--
.../broker/admin/impl/PersistentTopicsBase.java | 25 +-
.../pulsar/broker/service/AbstractReplicator.java | 340 +++++++++----
.../pulsar/broker/service/BrokerService.java | 2 +-
.../apache/pulsar/broker/service/Replicator.java | 6 +-
.../nonpersistent/NonPersistentReplicator.java | 5 +-
.../service/nonpersistent/NonPersistentTopic.java | 8 +-
.../service/persistent/PersistentReplicator.java | 96 ++--
.../broker/service/persistent/PersistentTopic.java | 203 ++++++--
.../broker/service/AbstractReplicatorTest.java | 22 +-
.../broker/service/OneWayReplicatorTest.java | 534 ++++++++++++++++++++-
.../broker/service/OneWayReplicatorTestBase.java | 61 ++-
.../pulsar/broker/service/PersistentTopicTest.java | 6 +-
.../broker/service/ReplicatorGlobalNSTest.java | 128 +++--
.../pulsar/broker/service/ReplicatorTest.java | 144 ++----
.../service/persistent/PersistentTopicTest.java | 81 +++-
.../org/apache/pulsar/common/util/FutureUtil.java | 33 +-
17 files changed, 1432 insertions(+), 366 deletions(-)
