This is an automated email from the ASF dual-hosted git repository.
bogong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.9 by this push:
new cf6f3f6e0c3 Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
cf6f3f6e0c3 is described below
commit cf6f3f6e0c3ec5ab0a3a19fc6d91dcbf6abe3bab
Author: Kai Wang <[email protected]>
AuthorDate: Wed Jul 13 08:54:27 2022 +0800
Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
(cherry picked from commit d96243ff0c1ab36240bd744742ef82cbf64565fd)
---
.../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 37d4ce7f2fc..1242980498d 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";