Fixed flaky test testAccumulativeStats() (apache#10820)

xche · Jun 7, 2021 · 680b95b · 680b95b
1 parent f25b4a5
commit 680b95b
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/.../src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java b/.../src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopicTest.java
@@ -69,7 +69,6 @@ public void testAccumulativeStats() throws Exception {
         assertEquals(stats.getBytesOutCounter(), 0);
         assertEquals(stats.getMsgOutCounter(), 0);
 
-        producer.newMessage().value("test").eventTime(5).send();
         producer.newMessage().value("test").eventTime(5).send();
 
         Message<String> msg = consumer1.receive();

diff --git a/...broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java b/...broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
@@ -212,7 +212,6 @@ public void testAccumulativeStats() throws Exception {
         assertEquals(stats.getBytesOutCounter(), 0);
         assertEquals(stats.getMsgOutCounter(), 0);
 
-        producer.newMessage().value("test").eventTime(5).send();
         producer.newMessage().value("test").eventTime(5).send();
 
         Message<String> msg = consumer1.receive();