Change test group to broker for ReplicatorTest and fix the test (#11134)

(cherry picked from commit 417667d)
apache · Jun 29, 2021 · 7415036 · 7415036
1 parent 6cecb5a
commit 7415036
Showing 1 changed file with 9 additions and 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
@@ -85,7 +85,6 @@
 import org.mockito.Mockito;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.testng.Assert;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.BeforeMethod;
@@ -824,17 +823,17 @@ public void testReplicatorWithPartitionedTopic() throws Exception {
         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);
     }
 
     /**