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

[bogong]

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

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

    [fix][flaky-test] Fix PersistentTopicStreamingDispatcherTest (#16801)
    
    (cherry picked from commit bdd87794a0ad6a775a911e9cb27cf6fbaf02d9e8)
---
 .../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 b0ef7793e29..778a5b00caa 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().setStreamingDispatch(true);