From aff185cf4a9884d49372467da861ea728b007d7e Mon Sep 17 00:00:00 2001 From: Matteo Merli Date: Sun, 5 Apr 2026 08:02:07 -0700 Subject: [PATCH] [fix][test] Fix flaky MessageChunkingSharedTest.testMultiConsumers timeout Increase Awaitility timeout from 3 seconds to 15 seconds. Chunked message reassembly across two shared consumers with 40 total chunks can take longer than 3 seconds under CI load. --- .../apache/pulsar/client/impl/MessageChunkingSharedTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java index ff31409a24188..049aea35df0ce 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java @@ -118,7 +118,7 @@ public void testMultiConsumers() throws Exception { producer.send(value); } - Awaitility.await().atMost(Duration.ofSeconds(3)) + Awaitility.await().atMost(Duration.ofSeconds(15)) .until(() -> receivedValues1.size() + receivedValues2.size() >= values.size()); assertEquals(receivedValues1.size() + receivedValues2.size(), values.size()); assertFalse(receivedValues1.isEmpty());