[pulsar] branch branch-2.7 updated: Change test group to broker for ReplicatorTest and fix the test (#11134)

[penghui]

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

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


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new 7415036  Change test group to broker for ReplicatorTest and fix the 
test (#11134)
7415036 is described below

commit 74150361740d15bb40caddaa0d9664da4c753287
Author: lipenghui <peng...@apache.org>
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  | 19 +++++++++----------
 1 file changed, 9 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 26819c8..75e214f 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
@@ -85,7 +85,6 @@ import org.awaitility.Awaitility;
 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 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);
     }
 
     /**