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 2787d1ff3b52f78db31f381901380603c48696af Author: Jiwei Guo <[email protected]> AuthorDate: Thu Jul 28 09:10:53 2022 +0800 Fix Flaky-test: PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809) (cherry picked from commit d8b00d9c5224d900f3224b24a1e0d3dd787eb933) --- .../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();
