[pulsar] branch master updated: [fix][test] Fix flaky OneWayReplicatorTest.testReplicatorProducerStatInTopic (#21334)

[tison]

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

tison 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 16199d2d155 [fix][test] Fix flaky 
OneWayReplicatorTest.testReplicatorProducerStatInTopic (#21334)
16199d2d155 is described below

commit 16199d2d15556ee5a19044eb739d88a01b1573e5
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Tue Oct 10 01:39:58 2023 +0300

    [fix][test] Fix flaky 
OneWayReplicatorTest.testReplicatorProducerStatInTopic (#21334)
---
 .../java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java | 6 ------
 1 file changed, 6 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
index e068cd55e90..8269f40e608 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
@@ -26,7 +26,6 @@ import java.util.concurrent.TimeUnit;
 import org.apache.pulsar.broker.BrokerTestUtil;
 import org.apache.pulsar.broker.service.persistent.PersistentTopic;
 import org.apache.pulsar.client.api.Consumer;
-import org.apache.pulsar.client.api.MessageId;
 import org.apache.pulsar.client.api.Producer;
 import org.apache.pulsar.client.api.Schema;
 import org.apache.pulsar.common.policies.data.TopicStats;
@@ -56,11 +55,6 @@ public class OneWayReplicatorTest extends 
OneWayReplicatorTestBase {
         final String subscribeName = "subscribe_1";
         final byte[] msgValue = "test".getBytes();
 
-        admin1.topics().createNonPartitionedTopic(topicName);
-        admin2.topics().createNonPartitionedTopic(topicName);
-        admin1.topics().createSubscription(topicName, subscribeName, 
MessageId.earliest);
-        admin2.topics().createSubscription(topicName, subscribeName, 
MessageId.earliest);
-
         // Verify replicator works.
         Producer<byte[]> producer1 = 
client1.newProducer().topic(topicName).create();
         Consumer<byte[]> consumer2 = 
client2.newConsumer().topic(topicName).subscriptionName(subscribeName).subscribe();