This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d6ff92223ba3dc78f7e975a957a7590323dea830 Author: lipenghui <[email protected]> AuthorDate: Tue Jul 5 09:04:30 2022 +0800 [fix][flaky-test] Fix failed test PatternTopicsConsumerImplTest.testAutoSubscribePatternConsumer (#16375) (cherry picked from commit bd2c3e4da9add3d60e37676eec73400483846325) --- .../pulsar/client/impl/PatternTopicsConsumerImplTest.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java index 5eaeea1f45e..69ef971ed61 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java @@ -46,6 +46,7 @@ import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.api.SubscriptionType; import org.apache.pulsar.common.naming.NamespaceName; import org.apache.pulsar.common.policies.data.TenantInfoImpl; +import org.awaitility.Awaitility; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.testng.annotations.AfterMethod; @@ -648,10 +649,11 @@ public class PatternTopicsConsumerImplTest extends ProducerConsumerBase { log.debug("recheck topics change"); PatternMultiTopicsConsumerImpl<byte[]> consumer1 = ((PatternMultiTopicsConsumerImpl<byte[]>) consumer); consumer1.run(consumer1.getRecheckPatternTimeout()); - Thread.sleep(100); - assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitions().size(), 10); - assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getConsumers().size(), 10); - assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 3); + Awaitility.await().untilAsserted(() -> { + assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitions().size(), 10); + assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getConsumers().size(), 10); + assertEquals(((PatternMultiTopicsConsumerImpl<?>) consumer).getPartitionedTopics().size(), 3); + }); // 8. produce data to topic3 and topic4, verify should receive all the message for (int i = 0; i < totalMessages / 2; i++) {
