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 7b74d89f6ae correcting spelling mistakes
7b74d89f6ae is described below
commit 7b74d89f6ae0f9117b955280da32d2a6619d4c93
Author: zhangwd3 <[email protected]>
AuthorDate: Tue May 16 11:23:11 2023 +0800
correcting spelling mistakes
Signed-off-by: zhangwd3 <[email protected]>
(cherry picked from commit ff58c6203ba6367f8ba293bc1a4e994725b5758a)
---
.../java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java | 2 +-
.../pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java | 2 +-
.../java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java | 2 +-
.../java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java | 2 +-
.../src/main/java/org/apache/pulsar/client/api/Reader.java | 4 ++--
5 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java
index 42ef264b6db..c9fce46a305 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java
@@ -118,7 +118,7 @@ public class LinuxInfoUtils {
* </pre>
* <p>
* Line is split in "words", filtering the first. The sum of all numbers
give the amount of cpu cycles used this
- * far. Real CPU usage should equal the sum substracting the idle cycles,
this would include iowait, irq and steal.
+ * far. Real CPU usage should equal the sum subtracting the idle cycles,
this would include iowait, irq and steal.
*/
public static ResourceUsage getCpuUsageForEntireHost() {
try (Stream<String> stream = Files.lines(Paths.get(PROC_STAT_PATH))) {
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java
index 318f37f7f7a..8412658d86a 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java
@@ -155,7 +155,7 @@ public class LinuxBrokerHostUsageImpl implements
BrokerHostUsage {
* </pre>
*
* Line is split in "words", filtering the first. The sum of all numbers
give the amount of cpu cycles used this
- * far. Real CPU usage should equal the sum substracting the idle cycles,
this would include iowait, irq and steal.
+ * far. Real CPU usage should equal the sum subtracting the idle cycles,
this would include iowait, irq and steal.
*/
private double getTotalCpuUsageForEntireHost() {
LinuxInfoUtils.ResourceUsage cpuUsageForEntireHost =
getCpuUsageForEntireHost();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 1bc437195d9..f3a00531eba 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -3136,7 +3136,7 @@ public class SimpleProducerConsumerTest extends
ProducerConsumerBase {
pulsarClient.newProducer().topic("persistent://my-property/my-ns/myenc-topic1")
.addEncryptionKey("client-non-existant-rsa.pem").cryptoKeyReader(new
EncKeyReader())
.create();
- Assert.fail("Producer creation should not suceed if failing to
read key");
+ Assert.fail("Producer creation should not succeed if failing to
read key");
} catch (Exception e) {
// ok
}
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
index 9f94d894632..e126d963a88 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
@@ -2296,7 +2296,7 @@ public class V1_ProducerConsumerTest extends
V1_ProducerConsumerBase {
.addEncryptionKey("client-non-existant-rsa.pem")
.cryptoKeyReader(new EncKeyReader())
.create();
- Assert.fail("Producer creation should not suceed if failing to
read key");
+ Assert.fail("Producer creation should not succeed if failing to
read key");
} catch (Exception e) {
// ok
}
diff --git
a/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Reader.java
b/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Reader.java
index 451b9fa6382..98fcdb453bb 100644
---
a/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Reader.java
+++
b/pulsar-client-1x-base/pulsar-client-1x/src/main/java/org/apache/pulsar/client/api/Reader.java
@@ -36,14 +36,14 @@ public interface Reader extends Closeable {
/**
* Read the next message in the topic.
*
- * @return the next messasge
+ * @return the next message
* @throws PulsarClientException
*/
Message<byte[]> readNext() throws PulsarClientException;
/**
* Read the next message in the topic waiting for a maximum of timeout
- * time units. Returns null if no message is recieved in that time.
+ * time units. Returns null if no message is received in that time.
*
* @return the next message(Could be null if none received in time)
* @throws PulsarClientException
