[pulsar] branch master updated: [fix][flaky-test] Fix PersistentTopicStreamingDispatcherTest (#16801)

[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 bdd87794a0a [fix][flaky-test] Fix 
PersistentTopicStreamingDispatcherTest (#16801)
bdd87794a0a is described below

commit bdd87794a0ad6a775a911e9cb27cf6fbaf02d9e8
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Wed Jul 27 10:34:28 2022 +0800

    [fix][flaky-test] Fix PersistentTopicStreamingDispatcherTest (#16801)
---
 .../service/persistent/PersistentTopicStreamingDispatcherTest.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicStreamingDispatcherTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicStreamingDispatcherTest.java
index bbe796e93e8..50aafd2ef1c 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicStreamingDispatcherTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicStreamingDispatcherTest.java
@@ -29,7 +29,7 @@ import org.testng.annotations.Test;
 @Test(groups = "broker")
 public class PersistentTopicStreamingDispatcherTest extends 
PersistentTopicTest {
 
-    @BeforeMethod
+    @BeforeMethod(alwaysRun = true)
     public void setup() throws Exception {
         super.setup();
         pulsar.getConfiguration().setTopicLevelPoliciesEnabled(false);