You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2022/08/01 02:23:21 UTC
[pulsar] branch master updated: [typos]fix some typos (#16706)
This is an automated email from the ASF dual-hosted git repository.
zhangmingao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new d1ac58f568f [typos]fix some typos (#16706)
d1ac58f568f is described below
commit d1ac58f568f754b39cc9726f9423813fa1b86e46
Author: lixinyang <84...@users.noreply.github.com>
AuthorDate: Mon Aug 1 10:23:13 2022 +0800
[typos]fix some typos (#16706)
* fix some typos
* fix some typos
Co-authored-by: nicklixinyang <ni...@didiglobal.com>
---
.../java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java | 4 ++--
.../java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java | 6 +++---
.../java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java | 6 +++---
.../pulsar/common/policies/impl/NamespaceIsolationPolicies.java | 2 +-
4 files changed, 9 insertions(+), 9 deletions(-)
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 91ffe650ac3..84753229fd0 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
@@ -705,7 +705,7 @@ public abstract class NamespacesBase extends AdminResource {
.thenCompose(__ -> authService.grantSubscriptionPermissionAsync(namespaceName, subscription,
roles, null))
.thenAccept(unused -> {
- log.info("[{}] Successfully granted permssion on subscription for role {}:{} - "
+ log.info("[{}] Successfully granted permission on subscription for role {}:{} - "
+ "namespaceName {}", clientAppId(), roles, subscription, namespaceName);
})
.exceptionally(ex -> {
@@ -1136,7 +1136,7 @@ public abstract class NamespacesBase extends AdminResource {
&& (splitBoundaries == null || splitBoundaries.size() == 0)) {
throw new RestException(Status.PRECONDITION_FAILED,
"With specified_positions_divide split algorithm, splitBoundaries must not be "
- + "emtpy");
+ + "empty");
}
}
})
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
index 51a0cb1598d..d8a9cdc7ce4 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
@@ -267,7 +267,7 @@ public class PersistentTopics extends PersistentTopicsBase {
*/
@POST
@Path("/{property}/{cluster}/{namespace}/{topic}/partitions")
- @ApiOperation(hidden = true, value = "Increment partitons of an existing partitioned topic.",
+ @ApiOperation(hidden = true, value = "Increment partitions of an existing partitioned topic.",
notes = "It only increments partitions of existing non-global partitioned-topic")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@@ -686,7 +686,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@Path("/{property}/{cluster}/{namespace}/{topic}/subscription/{subName}/resetcursor/{timestamp}")
@ApiOperation(hidden = true,
value = "Reset subscription to message position closest to absolute timestamp (in ms).",
- notes = "It fence cursor and disconnects all active consumers before reseting cursor.")
+ notes = "It fence cursor and disconnects all active consumers before resetting cursor.")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 403, message = "Don't have admin permission"),
@@ -720,7 +720,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@POST
@Path("/{property}/{cluster}/{namespace}/{topic}/subscription/{subName}/resetcursor")
@ApiOperation(hidden = true, value = "Reset subscription to message position closest to given position.",
- notes = "It fence cursor and disconnects all active consumers before reseting cursor.")
+ notes = "It fence cursor and disconnects all active consumers before resetting cursor.")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 403, message = "Don't have admin permission"),
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
index 854adf98ac3..6be6490fd0b 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
@@ -89,7 +89,7 @@ public class PersistentTopics extends PersistentTopicsBase {
response = String.class, responseContainer = "List")
@ApiResponses(value = {
@ApiResponse(code = 401, message = "Don't have permission to administrate resources on this tenant"),
- @ApiResponse(code = 403, message = "Don't have admin or operate permission on the namespacee"),
+ @ApiResponse(code = 403, message = "Don't have admin or operate permission on the namespace"),
@ApiResponse(code = 404, message = "tenant/namespace/topic doesn't exit"),
@ApiResponse(code = 412, message = "Namespace name is not valid"),
@ApiResponse(code = 500, message = "Internal server error")})
@@ -1564,7 +1564,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@POST
@Path("/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor/{timestamp}")
@ApiOperation(value = "Reset subscription to message position closest to absolute timestamp (in ms).",
- notes = "It fence cursor and disconnects all active consumers before reseting cursor.")
+ notes = "It fence cursor and disconnects all active consumers before resetting cursor.")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 401, message = "Don't have permission to administrate resources on this tenant or"
@@ -1733,7 +1733,7 @@ public class PersistentTopics extends PersistentTopicsBase {
@POST
@Path("/{tenant}/{namespace}/{topic}/subscription/{subName}/resetcursor")
@ApiOperation(value = "Reset subscription to message position closest to given position.",
- notes = "It fence cursor and disconnects all active consumers before reseting cursor.")
+ notes = "It fence cursor and disconnects all active consumers before resetting cursor.")
@ApiResponses(value = {
@ApiResponse(code = 307, message = "Current broker doesn't serve the namespace of this topic"),
@ApiResponse(code = 401, message = "Don't have permission to administrate resources on this tenant or"
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicies.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicies.java
index eb32addef65..1af7fdc0c3c 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicies.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicies.java
@@ -135,7 +135,7 @@ public class NamespaceIsolationPolicies {
* @param nsPolicy
* The namespace name
* @param brokerAddress
- * The broker adderss is the format of host:port
+ * The broker address is the format of host:port
* @return The broker assignment: {primary, secondary, shared}
*/
private BrokerAssignment getBrokerAssignment(NamespaceIsolationPolicy nsPolicy, String brokerAddress) {