You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/12/21 09:32:51 UTC
(pulsar) 01/05: [fix][test] Fix flaky KeySharedSubscriptionTest.testNoKeySendAndReceiveWithHashRangeAutoSplitStickyKeyConsumerSelector (#23747)
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 <52...@users.noreply.github.com>
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")