Skip to content

Commit 1566e01

Browse files
author
Masahiro Sakamoto
committed
Fix flaky test: KeySharedSubscriptionTest.testCanRecoverConsumptionWhenLiftMaxUnAckedMessagesRestriction
1 parent dacfe6a commit 1566e01

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeySharedSubscriptionTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public void testCanRecoverConsumptionWhenLiftMaxUnAckedMessagesRestriction(Subsc
146146

147147
// Wait for all consumers to continue receiving messages.
148148
Awaitility.await()
149-
.atMost(15, TimeUnit.SECONDS)
149+
.atMost(30, TimeUnit.SECONDS)
150150
.pollDelay(5, TimeUnit.SECONDS)
151151
.until(() ->
152152
(System.currentTimeMillis() - lastActiveTime.get()) > TimeUnit.SECONDS.toMillis(5));

0 commit comments

Comments
 (0)