You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/18 07:59:36 UTC
[pulsar] 14/16: [flaky-test] SubscriptionSeekTest.testSeekForBatchMessageAndSpecifiedBatchIndex (#14676) (#14689)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b5f3f244cbcd84ec0c0f13eac08ef0395effd36a
Author: llIlll <10...@users.noreply.github.com>
AuthorDate: Wed Mar 16 12:18:39 2022 +0800
[flaky-test] SubscriptionSeekTest.testSeekForBatchMessageAndSpecifiedBatchIndex (#14676) (#14689)
(cherry picked from commit 2d3e802293c62cf408ca52c1ff76efa713542f6e)
---
.../java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java
index 76d8c0b..b59eb95 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SubscriptionSeekTest.java
@@ -187,7 +187,7 @@ public class SubscriptionSeekTest extends BrokerTestBase {
@Test
public void testSeekForBatchMessageAndSpecifiedBatchIndex() throws Exception {
- final String topicName = "persistent://prop/use/ns-abcd/testSeekForBatch";
+ final String topicName = "persistent://prop/use/ns-abcd/testSeekForBatchMessageAndSpecifiedBatchIndex";
String subscriptionName = "my-subscription-batch";
Producer<String> producer = pulsarClient.newProducer(Schema.STRING)