(pulsar) branch master updated: [fix][test]Fix flaky test V1_ProducerConsumerTest.testConcurrentConsumerReceiveWhileReconnect (#24019)

[mmerli]

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

mmerli 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 2c686d0ab1e [fix][test]Fix flaky test 
V1_ProducerConsumerTest.testConcurrentConsumerReceiveWhileReconnect (#24019)
2c686d0ab1e is described below

commit 2c686d0ab1ea3f697dea4f5ce7938282b9b06f88
Author: fengyubiao <yubiao.f...@streamnative.io>
AuthorDate: Tue Feb 25 14:48:55 2025 +0800

    [fix][test]Fix flaky test 
V1_ProducerConsumerTest.testConcurrentConsumerReceiveWhileReconnect (#24019)
---
 .../org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
index 0b3ff345acf..255591ea7da 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
@@ -589,9 +589,11 @@ public class V1_ProducerConsumerTest extends 
V1_ProducerConsumerBase {
         restartBroker();
 
         // The available permits should be 10 and num messages in the queue 
should be 90
-        Awaitility.await().untilAsserted(() ->
-                Assert.assertEquals(consumerImpl.getAvailablePermits(), 
numConsumersThreads));
-        Assert.assertEquals(consumerImpl.numMessagesInQueue(), recvQueueSize - 
numConsumersThreads);
+        Awaitility.await().untilAsserted(() -> {
+            Assert.assertEquals(consumerImpl.getAvailablePermits(), 
numConsumersThreads);
+            Assert.assertEquals(consumerImpl.numMessagesInQueue(), 
recvQueueSize - numConsumersThreads);
+        });
+
         consumer.close();
     }