Skip to content

Commit

Permalink
Update NamespacesBase.java
Browse files Browse the repository at this point in the history
  • Loading branch information
gaozhangmin committed Aug 23, 2022
1 parent 7948e0c commit fe2dce3
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -310,7 +310,7 @@ protected CompletableFuture<Void> internalDeleteNamespaceAsync() {
.getNamespaceBundleFactory()
.getBundles(namespaceName);
for (NamespaceBundle bundle : bundles.getBundles()) {
// check if the bundle is owned by any broker,
// check if the bundle is owned by any broker,
// if not then we do not need to delete the bundle
deleteBundleFutures.add(pulsar().getNamespaceService()
.getOwnerAsync(bundle).thenCompose(ownership -> {
Expand Down

0 comments on commit fe2dce3

Please sign in to comment.