This is an automated email from the ASF dual-hosted git repository. bogong pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 961d5b5094baffe40616964ab6b7d53b60bf2a37 Author: congbobo184 <[email protected]> AuthorDate: Fri Nov 18 15:42:10 2022 +0800 fix #18491 import incorrect class --- .../src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java index a340423a6d1..e13e07dfddf 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java @@ -35,7 +35,7 @@ import org.apache.pulsar.client.api.ProducerConsumerBase; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.api.SubscriptionType; import org.awaitility.Awaitility; -import org.testcontainers.shaded.org.awaitility.reflect.WhiteboxImpl; +import org.awaitility.reflect.WhiteboxImpl; import org.testng.Assert; import org.testng.annotations.AfterClass; import org.testng.annotations.BeforeClass; @@ -235,7 +235,7 @@ public class NegativeAcksTest extends ProducerConsumerBase { Assert.assertEquals(0, datas.size()); } - @Test(invocationCount = 5) + @Test public void testMultiTopicConsumerConcurrentRedeliverAndReceive() throws Exception { final String topic = BrokerTestUtil.newUniqueName("my-topic"); admin.topics().createPartitionedTopic(topic, 2);
