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/28 13:33:27 UTC
[pulsar] 01/01: Change test group to broker for ReplicatorTest and
fix the test
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 <pe...@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);
}
/**