You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/08/08 09:04:15 UTC
[pulsar] 11/33: [fix][flaky-test] Fix PersistentTopicStreamingDispatcherTest (#16801)
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 <no...@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);