You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/07/17 10:44:34 UTC
(pulsar) 01/08: [fix][test] Fix flaky test SimpleProducerConsumerStatTest#testPartitionTopicStats (#21642)
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 <te...@apache.org>
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);