[fix][flaky-test] Fix PersistentTopicStreamingDispatcherTest
@@ -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);
