You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/06/29 00:38:25 UTC
[pulsar] branch master updated: Change test group to broker for
ReplicatorTest and fix the test (#11134)
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 <pe...@apache.org>
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);
}
/**