From faf8a78c0774224070d00db42b5765c7f31e39ea Mon Sep 17 00:00:00 2001 From: feynmanlin Date: Sun, 8 Aug 2021 23:02:27 +0800 Subject: [PATCH] Fix all threads will get stuck when deleting the namespace (#11596) --- .../org/apache/pulsar/broker/admin/impl/NamespacesBase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java index ae707be70f06e6..96dd402f1bca17 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java @@ -227,7 +227,8 @@ protected void internalDeleteNamespace(AsyncResponse asyncResponse, boolean auth boolean isEmpty; List topics; try { - topics = pulsar().getNamespaceService().getListOfPersistentTopics(namespaceName).join(); + topics = pulsar().getNamespaceService().getListOfPersistentTopics(namespaceName) + .get(config().getZooKeeperOperationTimeoutSeconds(), TimeUnit.SECONDS); topics.addAll(getPartitionedTopicList(TopicDomain.persistent)); topics.addAll(getPartitionedTopicList(TopicDomain.non_persistent)); isEmpty = topics.isEmpty();