This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 070cbd687731068623e3f0ee6359f98dcdbfdbf7 Author: Jiwei Guo <[email protected]> AuthorDate: Wed Nov 29 22:13:38 2023 +0800 [fix][test] Fix flaky test SimpleProducerConsumerStatTest#testPartitionTopicStats (#21642) (cherry picked from commit 93ed61bf9bf3470af8f44c170c4ae41b8a57f466) --- .../apache/pulsar/client/api/SimpleProducerConsumerStatTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java index 40e401d2866..5f3496d9859 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java @@ -46,6 +46,7 @@ import org.apache.pulsar.client.admin.PulsarAdminException; import org.awaitility.Awaitility; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.testng.Assert; import org.testng.annotations.AfterMethod; import org.testng.annotations.BeforeMethod; import org.testng.annotations.DataProvider; @@ -495,9 +496,10 @@ public class SimpleProducerConsumerStatTest extends ProducerConsumerBase { msg = consumer.receive(5, TimeUnit.SECONDS); String receivedMessage = new String(msg.getData()); log.info("Received message: [{}]", receivedMessage); - String expectedMessage = "my-message-" + i; - testMessageOrderAndDuplicates(messageSet, receivedMessage, expectedMessage); + Assert.assertTrue(messageSet.add(receivedMessage), "Received duplicate message " + receivedMessage); } + Assert.assertEquals(messageSet.size(), numMessages); + // Acknowledge the consumption of all messages at once consumer.acknowledgeCumulative(msg);
