This is an automated email from the ASF dual-hosted git repository.
mmerli 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 eac628f68fa [fix][test] Fix flaky
MessageChunkingSharedTest.testMultiConsumers timeout (#25475)
eac628f68fa is described below
commit eac628f68faa2f680ec70c347affe7e785547965
Author: Matteo Merli <[email protected]>
AuthorDate: Sun Apr 5 20:15:33 2026 -0700
[fix][test] Fix flaky MessageChunkingSharedTest.testMultiConsumers timeout
(#25475)
---
.../java/org/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 ff31409a241..049aea35df0 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 class MessageChunkingSharedTest extends
SharedPulsarBaseTest {
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());