(pulsar) branch master updated: [fix][test] Fix flaky KeySharedSubscriptionTest.testNoKeySendAndReceiveWithHashRangeAutoSplitStickyKeyConsumerSelector (#23747)

[lhotari]

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

lhotari 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 a54be73e95e [fix][test] Fix flaky 
KeySharedSubscriptionTest.testNoKeySendAndReceiveWithHashRangeAutoSplitStickyKeyConsumerSelector
 (#23747)
a54be73e95e is described below

commit a54be73e95e02f12e6656acb46c339c81dc0e531
Author: Philipp Dolif <52791955+pdo...@users.noreply.github.com>
AuthorDate: Fri Dec 20 12:39:05 2024 +0100

    [fix][test] Fix flaky 
KeySharedSubscriptionTest.testNoKeySendAndReceiveWithHashRangeAutoSplitStickyKeyConsumerSelector
 (#23747)
---
 .../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")