[fix][test] Fix flaky MessageChunkingSharedTest.testMultiConsumers timeout (#25475)

merlimat · web-flow · commit eac628f68faa · 2026-04-05T20:15:33.000-07:00
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
@@ -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());

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ public void testMultiConsumers() throws Exception {`
`118`	`118`	`producer.send(value);`
`119`	`119`	`}`
`120`	`120`
`121`		`- Awaitility.await().atMost(Duration.ofSeconds(3))`
	`121`	`+ Awaitility.await().atMost(Duration.ofSeconds(15))`
`122`	`122`	`.until(() -> receivedValues1.size() + receivedValues2.size() >= values.size());`
`123`	`123`	`assertEquals(receivedValues1.size() + receivedValues2.size(), values.size());`
`124`	`124`	`assertFalse(receivedValues1.isEmpty());`