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 09098edf90d18fed3b3fbdbf53be5e55c1195c2b Author: Zixuan Liu <[email protected]> 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);
