You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/07/01 02:34:03 UTC
[GitHub] [pulsar] Technoboy- opened a new pull request, #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Technoboy- opened a new pull request, #16313:
URL: https://github.com/apache/pulsar/pull/16313
### Motivation
See PIP #14365 and change tracker #15043.
Make the `unloadNamespaceBundle` method in Namespaces to pure async.
This also fixes broker do rebalance to unload namespace bundle.
```
00:12:31.858 [pulsar-load-manager-1-1] WARN org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl - Error when trying to perform load shedding on. xxx/public/0xb0000000_0xc0000000 for broker 10.0.37.216:8080
org.apache.pulsar.client.admin.PulsarAdminException$ServerSideErrorException: HTTP 500 Internal Server Error
at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:219) ~[org.apache.pulsar-pulsar-client-admin-original-2.8.0.jar:2.8.0]
```
### Documentation
- [x] `no-need-doc`
(Please explain why)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] hepyu commented on pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
hepyu commented on PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#issuecomment-1175880638
I have a question:
we use pulsar-2.8.0 in pro env, but this pr was merged into master, could you please merge this pr into pulsar-2.8.0's new tag, then I can use this new tag to replace our pro env pulsar-2.8.0 directly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913843025
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
yes, right. However, for better code style and behavior, I still take your opinion.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913863173
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] hepyu commented on pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
hepyu commented on PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#issuecomment-1175970573
And I have another question:
will this pr be released to which pulsar version?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- merged pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- merged PR #16313:
URL: https://github.com/apache/pulsar/pull/16313
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913326806
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
@eolivelli So it's no need to add try/catch block.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r912944160
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
Ah, because `validateNamespaceName ` will throw RestException, it's the same with putting it into try/catch block.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] eolivelli commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
eolivelli commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r912940019
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
why aren't we wrapping this into a try/catch block as before ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#issuecomment-1173707010
> Please fix the check style validation.
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] eolivelli commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
eolivelli commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913835919
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
so throwing RestException is like calling `asyncResponse.resume(new RestException(e));` ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913833407
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
yes, I know what you mean. Before this pr, I have tested locally not added try/catch block, it’s the same with you comment
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] shibd commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
shibd commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r912379600
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java:
##########
@@ -1074,76 +1105,50 @@ protected BookieAffinityGroupData internalGetBookieAffinityGroup() {
}
}
- @SuppressWarnings("deprecation")
- public void internalUnloadNamespaceBundle(AsyncResponse asyncResponse, String bundleRange, boolean authoritative) {
- validateSuperUserAccess();
- checkNotNull(bundleRange, "BundleRange should not be null");
- log.info("[{}] Unloading namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange);
-
- Policies policies = getNamespacePolicies(namespaceName);
-
- NamespaceBundle bundle =
- pulsar().getNamespaceService().getNamespaceBundleFactory()
- .getBundle(namespaceName.toString(), bundleRange);
- boolean isOwnedByLocalCluster = false;
- try {
- isOwnedByLocalCluster = pulsar().getNamespaceService().isNamespaceBundleOwned(bundle).get();
- } catch (Exception e) {
- if (log.isDebugEnabled()) {
- log.debug("Failed to validate cluster ownership for {}-{}, {}",
- namespaceName.toString(), bundleRange, e.getMessage(), e);
- }
- }
-
- // validate namespace ownership only if namespace is not owned by local-cluster (it happens when broker doesn't
- // receive replication-cluster change watch and still owning bundle
- if (!isOwnedByLocalCluster) {
- if (namespaceName.isGlobal()) {
- // check cluster ownership for a given global namespace: redirect if peer-cluster owns it
- validateGlobalNamespaceOwnership(namespaceName);
- } else {
- validateClusterOwnership(namespaceName.getCluster());
- validateClusterForTenant(namespaceName.getTenant(), namespaceName.getCluster());
- }
- }
-
- validatePoliciesReadOnlyAccess();
-
- isBundleOwnedByAnyBroker(namespaceName, policies.bundles, bundleRange).thenAccept(flag -> {
- if (!flag) {
- log.info("[{}] Namespace bundle is not owned by any broker {}/{}", clientAppId(), namespaceName,
- bundleRange);
- asyncResponse.resume(Response.noContent().build());
- return;
- }
- NamespaceBundle nsBundle;
-
- try {
- nsBundle = validateNamespaceBundleOwnership(namespaceName, policies.bundles, bundleRange,
- authoritative, true);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- return;
- }
-
- pulsar().getNamespaceService().unloadNamespaceBundle(nsBundle)
- .thenRun(() -> {
- log.info("[{}] Successfully unloaded namespace bundle {}", clientAppId(), nsBundle.toString());
- asyncResponse.resume(Response.noContent().build());
- }).exceptionally(ex -> {
- log.error("[{}] Failed to unload namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange,
- ex);
- asyncResponse.resume(new RestException(ex));
- return null;
- });
- }).exceptionally((ex) -> {
- if (ex.getCause() instanceof WebApplicationException) {
- asyncResponse.resume(ex.getCause());
- } else {
- asyncResponse.resume(new RestException(ex.getCause()));
- }
- return null;
- });
+ public CompletableFuture<Void> internalUnloadNamespaceBundleAsync(String bundleRange, boolean authoritative) {
+ return validateSuperUserAccessAsync()
+ .thenAccept(__ -> {
+ checkNotNull(bundleRange, "BundleRange should not be null");
+ log.info("[{}] Unloading namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange);
+ })
+ .thenApply(__ ->
+ pulsar().getNamespaceService().getNamespaceBundleFactory()
+ .getBundle(namespaceName.toString(), bundleRange)
+ )
+ .thenCompose(bundle -> pulsar().getNamespaceService().isNamespaceBundleOwned(bundle))
Review Comment:
Need to keep the same logic as the original? original logic: when throw exception, isOwnedByLocalCluster is false.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] Technoboy- commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
Technoboy- commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r912423157
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java:
##########
@@ -1074,76 +1105,50 @@ protected BookieAffinityGroupData internalGetBookieAffinityGroup() {
}
}
- @SuppressWarnings("deprecation")
- public void internalUnloadNamespaceBundle(AsyncResponse asyncResponse, String bundleRange, boolean authoritative) {
- validateSuperUserAccess();
- checkNotNull(bundleRange, "BundleRange should not be null");
- log.info("[{}] Unloading namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange);
-
- Policies policies = getNamespacePolicies(namespaceName);
-
- NamespaceBundle bundle =
- pulsar().getNamespaceService().getNamespaceBundleFactory()
- .getBundle(namespaceName.toString(), bundleRange);
- boolean isOwnedByLocalCluster = false;
- try {
- isOwnedByLocalCluster = pulsar().getNamespaceService().isNamespaceBundleOwned(bundle).get();
- } catch (Exception e) {
- if (log.isDebugEnabled()) {
- log.debug("Failed to validate cluster ownership for {}-{}, {}",
- namespaceName.toString(), bundleRange, e.getMessage(), e);
- }
- }
-
- // validate namespace ownership only if namespace is not owned by local-cluster (it happens when broker doesn't
- // receive replication-cluster change watch and still owning bundle
- if (!isOwnedByLocalCluster) {
- if (namespaceName.isGlobal()) {
- // check cluster ownership for a given global namespace: redirect if peer-cluster owns it
- validateGlobalNamespaceOwnership(namespaceName);
- } else {
- validateClusterOwnership(namespaceName.getCluster());
- validateClusterForTenant(namespaceName.getTenant(), namespaceName.getCluster());
- }
- }
-
- validatePoliciesReadOnlyAccess();
-
- isBundleOwnedByAnyBroker(namespaceName, policies.bundles, bundleRange).thenAccept(flag -> {
- if (!flag) {
- log.info("[{}] Namespace bundle is not owned by any broker {}/{}", clientAppId(), namespaceName,
- bundleRange);
- asyncResponse.resume(Response.noContent().build());
- return;
- }
- NamespaceBundle nsBundle;
-
- try {
- nsBundle = validateNamespaceBundleOwnership(namespaceName, policies.bundles, bundleRange,
- authoritative, true);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- return;
- }
-
- pulsar().getNamespaceService().unloadNamespaceBundle(nsBundle)
- .thenRun(() -> {
- log.info("[{}] Successfully unloaded namespace bundle {}", clientAppId(), nsBundle.toString());
- asyncResponse.resume(Response.noContent().build());
- }).exceptionally(ex -> {
- log.error("[{}] Failed to unload namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange,
- ex);
- asyncResponse.resume(new RestException(ex));
- return null;
- });
- }).exceptionally((ex) -> {
- if (ex.getCause() instanceof WebApplicationException) {
- asyncResponse.resume(ex.getCause());
- } else {
- asyncResponse.resume(new RestException(ex.getCause()));
- }
- return null;
- });
+ public CompletableFuture<Void> internalUnloadNamespaceBundleAsync(String bundleRange, boolean authoritative) {
+ return validateSuperUserAccessAsync()
+ .thenAccept(__ -> {
+ checkNotNull(bundleRange, "BundleRange should not be null");
+ log.info("[{}] Unloading namespace bundle {}/{}", clientAppId(), namespaceName, bundleRange);
+ })
+ .thenApply(__ ->
+ pulsar().getNamespaceService().getNamespaceBundleFactory()
+ .getBundle(namespaceName.toString(), bundleRange)
+ )
+ .thenCompose(bundle -> pulsar().getNamespaceService().isNamespaceBundleOwned(bundle))
Review Comment:
fixed. thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] eolivelli commented on a diff in pull request #16313: [improve][broker] Make `unloadNamespaceBundle` async.
Posted by GitBox <gi...@apache.org>.
eolivelli commented on code in PR #16313:
URL: https://github.com/apache/pulsar/pull/16313#discussion_r913829640
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java:
##########
@@ -736,14 +736,20 @@ public BundlesData getBundlesData(@PathParam("property") String property, @PathP
@ApiResponse(code = 412, message = "Namespace is already unloaded or Namespace has bundles activated")})
public void unloadNamespace(@Suspended final AsyncResponse asyncResponse, @PathParam("property") String property,
@PathParam("cluster") String cluster, @PathParam("namespace") String namespace) {
- try {
- validateNamespaceName(property, cluster, namespace);
- internalUnloadNamespace(asyncResponse);
- } catch (WebApplicationException wae) {
- asyncResponse.resume(wae);
- } catch (Exception e) {
- asyncResponse.resume(new RestException(e));
- }
+ validateNamespaceName(property, cluster, namespace);
Review Comment:
you have asyncResponse, and you should not throw the exception but call
asyncResponse.resume(new RestException(e));
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org