From 358c5db5f56cb2d884e933d37bb4270fd32b13c1 Mon Sep 17 00:00:00 2001 From: leolinchen Date: Tue, 18 Oct 2022 00:14:55 +0800 Subject: [PATCH] Fix flaky test V1_ProducerConsumerTest#testActiveAndInActiveConsumerEntryCacheBehavior --- .../org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java index 097cf4823de26..9b1848c9ff3a4 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java @@ -698,6 +698,7 @@ public void testActiveAndInActiveConsumerEntryCacheBehavior() throws Exception { .topic("persistent://my-property/use/my-ns/" + topicName) .subscriptionName(sub2) .subscriptionType(SubscriptionType.Shared) + .receiverQueueSize(1) .subscribe(); // Produce messages final int moreMessages = 10;