This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 306e7cac83cbc9c75e5139a7ec794acc5f0af156 Author: fengyubiao <[email protected]> AuthorDate: Tue Feb 25 14:48:55 2025 +0800 [fix][test]Fix flaky test V1_ProducerConsumerTest.testConcurrentConsumerReceiveWhileReconnect (#24019) (cherry picked from commit 2c686d0ab1ea3f697dea4f5ce7938282b9b06f88) --- .../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 d3cb1d60d37..0c1de5708bb 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(); }
