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 cca4ac6a36fbb32e2137d444c043eb81ba580849 Author: Zixuan Liu <[email protected]> AuthorDate: Sat Apr 26 16:12:25 2025 +0800 [fix][test] Fix flaky BatchMessageWithBatchIndexLevelTest.testBatchMessageAck (#24212) Signed-off-by: Zixuan Liu <[email protected]> (cherry picked from commit 94c7a407a174215535abb34af03de1b1dc384ca1) --- .../pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java index 21a7c179b82..470c25e5909 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java @@ -85,7 +85,7 @@ public class BatchMessageWithBatchIndexLevelTest extends BatchMessageTest { .newConsumer() .topic(topicName) .subscriptionName(subscriptionName) - .receiverQueueSize(50) + .receiverQueueSize(numMsgs) .subscriptionType(SubscriptionType.Shared) .enableBatchIndexAcknowledgment(true) .negativeAckRedeliveryDelay(100, TimeUnit.MILLISECONDS)
