This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit ee3cad604c3cc1ba9b7f23454344ec9dffe90d88 Author: lipenghui <[email protected]> AuthorDate: Tue Jun 29 08:37:36 2021 +0800 Change test group to broker for ReplicatorTest and fix the test (#11134) (cherry picked from commit 417667dca078a5de5066b87dda8b74a956dcc479) --- .../apache/pulsar/broker/service/ReplicatorTest.java | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java index 0ea39aa..825d800 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java @@ -100,7 +100,7 @@ import org.testng.collections.Lists; /** * Starts 3 brokers that are in 3 different clusters */ -@Test(groups = "quarantine") +@Test(groups = "broker") public class ReplicatorTest extends ReplicatorTestBase { protected String methodName; @@ -835,17 +835,17 @@ public class ReplicatorTest extends ReplicatorTestBase { assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 5); assertEquals(admin2.topics().getList(namespace).size(), 5); // Update partitioned topic from R3 - admin3.topics().updatePartitionedTopic(persistentTopicName, 5); - assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 5); - assertEquals(admin3.topics().getList(namespace).size(), 5); - // Update partitioned topic from R1 - admin1.topics().updatePartitionedTopic(persistentTopicName, 6); - assertEquals(admin1.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6); - assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6); + admin3.topics().updatePartitionedTopic(persistentTopicName, 6); assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6); - assertEquals(admin1.topics().getList(namespace).size(), 6); - assertEquals(admin2.topics().getList(namespace).size(), 6); assertEquals(admin3.topics().getList(namespace).size(), 6); + // Update partitioned topic from R1 + admin1.topics().updatePartitionedTopic(persistentTopicName, 7); + assertEquals(admin1.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7); + assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7); + assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7); + assertEquals(admin1.topics().getList(namespace).size(), 7); + assertEquals(admin2.topics().getList(namespace).size(), 7); + assertEquals(admin3.topics().getList(namespace).size(), 7); } /**
