This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 417667d Change test group to broker for ReplicatorTest and fix the
test (#11134)
417667d is described below
commit 417667dca078a5de5066b87dda8b74a956dcc479
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)
---
.../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);
}
/**
