This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new 59022188cad [fix][test] Fix flaky test
org.apache.pulsar.broker.service.persistent.PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest#setup
(#18115)
59022188cad is described below
commit 59022188cad64fad4b399c5baf255ad00a806fb6
Author: LinChen <[email protected]>
AuthorDate: Thu Oct 20 10:15:03 2022 +0800
[fix][test] Fix flaky test
org.apache.pulsar.broker.service.persistent.PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest#setup
(#18115)
---
...tSubscriptionMessageDispatchStreamingDispatcherThrottlingTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest.java
index 1999307701c..042fb5f7bb1 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest.java
@@ -20,7 +20,7 @@ package org.apache.pulsar.broker.service.persistent;
import org.apache.pulsar.broker.service.streamingdispatch.StreamingDispatcher;
import org.apache.pulsar.client.api.SubscriptionMessageDispatchThrottlingTest;
-import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
/**
@@ -30,7 +30,7 @@ import org.testng.annotations.Test;
public class
PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest
extends SubscriptionMessageDispatchThrottlingTest {
- @BeforeMethod
+ @BeforeClass
@Override
protected void setup() throws Exception {
super.setup();