From fbfb8c2927eecbac8707aba81b628cfe7fcb79ac Mon Sep 17 00:00:00 2001 From: chenhang Date: Thu, 20 Oct 2022 09:17:35 +0800 Subject: [PATCH] fix failed test --- ...ptionMessageDispatchStreamingDispatcherThrottlingTest.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 1999307701ccc..042fb5f7bb1a4 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 @@ 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 @@ public class PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest extends SubscriptionMessageDispatchThrottlingTest { - @BeforeMethod + @BeforeClass @Override protected void setup() throws Exception { super.setup();