This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 2117be75bceb97e0e8c64c715e7ba94eb170a565 Author: Philipp Dolif <[email protected]> AuthorDate: Fri Dec 20 12:39:05 2024 +0100 [fix][test] Fix flaky KeySharedSubscriptionTest.testNoKeySendAndReceiveWithHashRangeAutoSplitStickyKeyConsumerSelector (#23747) (cherry picked from commit a54be73e95e02f12e6656acb46c339c81dc0e531) --- .../java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java index 08efb6d9583..92257c1df53 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java @@ -391,13 +391,14 @@ public class KeySharedSubscriptionTest extends ProducerConsumerBase { @Cleanup Producer<Integer> producer = createProducer(topic, enableBatch); - for (int i = 0; i < 100; i++) { + int totalMessages = 300; + for (int i = 0; i < totalMessages; i++) { producer.newMessage() .value(i) .send(); } - receiveAndCheckDistribution(Lists.newArrayList(consumer1, consumer2, consumer3), 100); + receiveAndCheckDistribution(Lists.newArrayList(consumer1, consumer2, consumer3), totalMessages); } @Test(dataProvider = "batch")
