[pulsar] branch master updated: [fix][test] Fix flaky AdminApiMaxUnackedMessagesTest.testMaxUnackedMessagesPerConsumerPriority (#21335)

[tison]

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

tison 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 c35524dae2d [fix][test] Fix flaky 
AdminApiMaxUnackedMessagesTest.testMaxUnackedMessagesPerConsumerPriority 
(#21335)
c35524dae2d is described below

commit c35524dae2d430d5ceb39b07e9124fac5d02648b
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Tue Oct 10 12:57:23 2023 +0300

    [fix][test] Fix flaky 
AdminApiMaxUnackedMessagesTest.testMaxUnackedMessagesPerConsumerPriority 
(#21335)
---
 .../org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
index 4fb268fc971..9b95e41bb64 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
@@ -197,7 +197,7 @@ public class AdminApiMaxUnackedMessagesTest extends 
MockedPulsarServiceBaseTest
     private List<Message> consumeMsg(Consumer<?> consumer, int msgNum) throws 
Exception {
         List<Message> list = new ArrayList<>();
         for (int i = 0; i <msgNum; i++) {
-            Message message = consumer.receive(500, TimeUnit.MILLISECONDS);
+            Message message = consumer.receive(1500, TimeUnit.MILLISECONDS);
             if (message == null) {
                 break;
             }