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 2021/09/02 05:36:38 UTC
[pulsar] 02/02: Fix cherry-pick issue after cherry-pick #11294
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0448c27ecad7de1f318bfb16fde6ce869965c0b1
Author: penghui <pe...@apache.org>
AuthorDate: Thu Sep 2 13:23:05 2021 +0800
Fix cherry-pick issue after cherry-pick #11294
---
.../src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
index c40b38a..9e2b9cf 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
@@ -2218,8 +2218,6 @@ public class TopicPoliciesTest extends MockedPulsarServiceBaseTest {
final String topic = "persistent://" + myNamespace + "/test-" + UUID.randomUUID();
admin.topics().createPartitionedTopic(topic, 1);
pulsarClient.newConsumer().topic(topic).subscriptionName("test").subscribe().close();
- Awaitility.await()
- .until(() -> pulsar.getTopicPoliciesService().cacheIsInitialized(TopicName.get(topic)));
Set<SubscriptionType> subscriptionTypeSet = new HashSet<>();
subscriptionTypeSet.add(SubscriptionType.Key_Shared);
admin.topics().setSubscriptionTypesEnabled(topic, subscriptionTypeSet);