[pulsar] branch master updated: Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)

[technoboy]

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 d96243ff0c1 Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
d96243ff0c1 is described below

commit d96243ff0c1ab36240bd744742ef82cbf64565fd
Author: Kai Wang <kw...@streamnative.io>
AuthorDate: Wed Jul 13 08:54:27 2022 +0800

    Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
---
 .../org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java
index fb1dbfea3f1..34e0c97e7d3 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/NonPersistentTopicE2ETest.java
@@ -199,7 +199,9 @@ public class NonPersistentTopicE2ETest extends 
BrokerTestBase {
 
         
assertTrue(pulsar.getBrokerService().getTopicReference(topicName).isPresent());
         runGC();
-        
assertFalse(pulsar.getBrokerService().getTopicReference(topicName).isPresent());
+        Awaitility.await().untilAsserted(() ->
+                
assertFalse(pulsar.getBrokerService().getTopicReference(topicName).isPresent())
+        );
 
         // 2. Topic is not GCed with live connection
         String subName = "sub1";