This is an automated email from the ASF dual-hosted git repository.
yubiao pushed a change to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from fccbc184d80 [fix] [ml] Mark delete stuck due to switching cursor
ledger fails (#22662)
new 7a614c088d0 [fix] [broker] Part-1: Replicator can not created
successfully due to an orphan replicator in the previous topic owner (#21946)
new 6d19109487d [improve] [broker] Create partitioned topics automatically
when enable topic level replication (#22537)
new 788124dcc5d [fix] [broker] Part-2: Replicator can not created
successfully due to an orphan replicator in the previous topic owner (#21948)
new 06a9fec57d1 [fix][broker] One topic can be closed multiple times
concurrently (#17524)
new 3a218dd8b3b [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 | 24 +-
.../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 | 10 +-
.../service/persistent/PersistentReplicator.java | 96 ++--
.../broker/service/persistent/PersistentTopic.java | 289 ++++++++---
.../broker/service/AbstractReplicatorTest.java | 22 +-
.../broker/service/OneWayReplicatorTest.java | 536 ++++++++++++++++++++-
.../broker/service/OneWayReplicatorTestBase.java | 61 ++-
.../pulsar/broker/service/PersistentTopicTest.java | 6 +-
.../broker/service/ReplicatorGlobalNSTest.java | 129 +++--
.../pulsar/broker/service/ReplicatorTest.java | 132 ++---
.../service/persistent/PersistentTopicTest.java | 81 +++-
.../org/apache/pulsar/common/util/FutureUtil.java | 33 +-
17 files changed, 1491 insertions(+), 385 deletions(-)
