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 <[email protected]> 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);
