Skip to content

Commit

Permalink
Fix all threads will get stuck when deleting the namespace (#11596)
Browse files Browse the repository at this point in the history
  • Loading branch information
315157973 authored Aug 8, 2021
1 parent a09bd68 commit c4a2572
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,8 @@ protected void internalDeleteNamespace(AsyncResponse asyncResponse, boolean auth
boolean isEmpty;
List<String> 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();
Expand Down

0 comments on commit c4a2572

Please sign in to comment.