[pulsar] branch master updated: Fixed flaky test testAccumulativeStats() (#10820)

[eolivelli]

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

eolivelli 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 680b95b  Fixed flaky test testAccumulativeStats() (#10820)
680b95b is described below

commit 680b95bcedf5cec15f307e7ae4db2145324ea4c2
Author: Andrey Yegorov <8622884+dl...@users.noreply.github.com>
AuthorDate: Mon Jun 7 07:25:10 2021 -0700

    Fixed flaky test testAccumulativeStats() (#10820)
---
 .../pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java      | 1 -
 .../org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java | 1 -
 2 files changed, 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java
index d43b046..bb64a98 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java
@@ -70,7 +70,6 @@ public class NonPersistentTopicTest extends BrokerTestBase {
         assertEquals(stats.getMsgOutCounter(), 0);
 
         producer.newMessage().value("test").eventTime(5).send();
-        producer.newMessage().value("test").eventTime(5).send();
 
         Message<String> msg = consumer1.receive();
         assertNotNull(msg);
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
index 14590a4..cb8ff33 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
@@ -213,7 +213,6 @@ public class PersistentTopicTest extends BrokerTestBase {
         assertEquals(stats.getMsgOutCounter(), 0);
 
         producer.newMessage().value("test").eventTime(5).send();
-        producer.newMessage().value("test").eventTime(5).send();
 
         Message<String> msg = consumer1.receive();
         assertNotNull(msg);