[pulsar] 01/01: Change test group to broker for ReplicatorTest and fix the test

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch penghui/remove_quarantine_replicator_test
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit a1b4c698f96366dec3606d1396d8f5a7ca0c9bf9
Author: penghui <peng...@apache.org>
AuthorDate: Mon Jun 28 21:29:49 2021 +0800

    Change test group to broker for ReplicatorTest and fix the test
---
 .../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);
     }
 
     /**