[pulsar] branch master updated: Fix Flaky-test: PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809)

[te...@apache.org]

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

technoboy 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 d8b00d9c522 Fix Flaky-test: PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809)
d8b00d9c522 is described below

commit d8b00d9c5224d900f3224b24a1e0d3dd787eb933
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Thu Jul 28 09:10:53 2022 +0800

    Fix Flaky-test: PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809)
---
 .../org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
index ec3e305c868..5f229dd580e 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
@@ -1025,6 +1025,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
         assertEquals(newProducerPartitions.get(), newPartitions);
         assertEquals(newConsumerPartitions.get(), newPartitions);
 
+        Awaitility.await().untilAsserted(() -> consumer.isConnected());
+
         producer.close();
         consumer.unsubscribe();
         consumer.close();