This is an automated email from the ASF dual-hosted git repository.
yubiao pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 60d7b8f93a4 [fix][doc] Correcting spelling mistakes (#20340)
60d7b8f93a4 is described below
commit 60d7b8f93a4be9310377eb1e0cc2f99cd71cd5af
Author: wangda <[email protected]>
AuthorDate: Wed May 17 19:43:42 2023 +0800
[fix][doc] Correcting spelling mistakes (#20340)
Signed-off-by: zhangwd3 <[email protected]>
Co-authored-by: tison <[email protected]>
(cherry picked from commit 1a66b640c3cd86bfca75dc9ab37bfdb37427a13f)
---
.../src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java | 2 +-
.../src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java | 2 +-
.../org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java | 2 +-
.../pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java | 2 +-
.../java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java | 2 +-
5 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java
b/pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java
index 526b0c96be0..8acbf26559b 100644
---
a/pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java
+++
b/pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java
@@ -210,7 +210,7 @@ public final class SchemaUtils {
}
/**
- * Jsonify the schema info with verison.
+ * Jsonify the schema info with version.
*
* @param schemaInfoWithVersion the schema info
* @return the jsonified schema info with version
diff --git
a/pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java
b/pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java
index 8e2f51c4edb..a02208396fc 100644
---
a/pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java
+++
b/pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessage.java
@@ -102,7 +102,7 @@ public interface RawMessage {
Optional<String> getKey();
/**
- * Get the schema verison of the message.
+ * Get the schema version of the message.
*
* @return the schema version of the message
*/
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java
index df1eae9b6a7..bf43f18b175 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java
@@ -166,7 +166,7 @@ public class BKStateStoreImpl implements DefaultStateStore {
data.readBytes(result);
// Set position to off the buffer to the
beginning, since the position after the
// read is going to be end of the buffer
- // If we do not rewind to the begining here, users
will have to explicitly do
+ // If we do not rewind to the beginning here,
users will have to explicitly do
// this in their function code
// in order to use any of the ByteBuffer operations
result.position(0);
diff --git
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
index 916b8e9a6e1..e611801250f 100644
---
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
+++
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
@@ -161,7 +161,7 @@ public class KubernetesSecretsTokenAuthProvider implements
KubernetesFunctionAut
.getFullyQualifiedName(funcDetails.getTenant(),
funcDetails.getNamespace(), funcDetails.getName());
String secretId = new String(functionAuthData.get().getData());
- // Make sure secretName is empty. Defensive programing
+ // Make sure secretName is empty. Defensive programming
if (isBlank(secretId)) {
log.warn("Secret name for function {} is empty.", fqfn);
return;
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
index 7daa9c9aee8..585b54d8461 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java
@@ -1437,7 +1437,7 @@ public abstract class ComponentImpl implements
Component<PulsarWorkerService> {
}
if (worker().getWorkerConfig().isAuthorizationEnabled()) {
- // to maintain backwards compatiblity but still have authorization
+ // to maintain backwards compatibility but still have authorization
String[] tokens = path.split("/");
if (tokens.length == 4) {
String tenant = tokens[0];