From 961d5b5094baffe40616964ab6b7d53b60bf2a37 Mon Sep 17 00:00:00 2001 From: congbobo184 Date: Fri, 18 Nov 2022 15:42:10 +0800 Subject: [PATCH] fix #18491 import incorrect class --- .../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 a340423a6d11a..e13e07dfddf37 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.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 void run() { 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);