(rocketmq) branch develop updated: [ISSUE #8782] Fix log typo (#8783)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new c5ac8a47ea [ISSUE #8782] Fix log typo (#8783)
c5ac8a47ea is described below

commit c5ac8a47ea9e84a05f63a26c771b25687d0e49dd
Author: luozongle01 <luozon...@hotmail.com>
AuthorDate: Sat Oct 5 10:09:07 2024 +0800

    [ISSUE #8782] Fix log typo (#8783)
---
 .../java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java | 2 +-
 .../src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java | 2 +-
 .../main/java/org/apache/rocketmq/store/AllocateMappedFileService.java  | 2 +-
 store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java     | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
index d53454f215..6dd8b30047 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
@@ -799,7 +799,7 @@ public class PullMessageProcessor implements 
NettyRequestProcessor {
                     }
                 }
             } catch (RemotingCommandException e1) {
-                LOGGER.error("excuteRequestWhenWakeup run", e1);
+                LOGGER.error("executeRequestWhenWakeup run", e1);
             }
         };
         this.brokerController.getPullMessageExecutor().submit(new 
RequestTask(run, channel, request));
diff --git 
a/openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java
 
b/openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java
index 36ac27f417..46e607a580 100644
--- 
a/openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java
+++ 
b/openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java
@@ -82,7 +82,7 @@ public class DefaultPromise<V> implements Promise<V> {
                         try {
                             lock.wait(waitTime);
                         } catch (InterruptedException e) {
-                            LOG.error("promise get value 
interrupted,excepiton:{}", e.getMessage());
+                            LOG.error("promise get value 
interrupted,exception:{}", e.getMessage());
                         }
 
                         if (!isDoing()) {
diff --git 
a/store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java 
b/store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
index 3dbc274ef0..d9cd602a65 100644
--- 
a/store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
+++ 
b/store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
@@ -132,7 +132,7 @@ public class AllocateMappedFileService extends 
ServiceThread {
         super.shutdown(true);
         for (AllocateRequest req : this.requestTable.values()) {
             if (req.mappedFile != null) {
-                log.info("delete pre allocated maped file, {}", 
req.mappedFile.getFileName());
+                log.info("delete pre allocated mapped file, {}", 
req.mappedFile.getFileName());
                 req.mappedFile.destroy(1000);
             }
         }
diff --git 
a/store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java 
b/store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
index e2a55d6399..99649398a8 100644
--- a/store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
+++ b/store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
@@ -356,7 +356,7 @@ public class PerfCounter {
                     }
 
                 } catch (Exception e) {
-                    logger.error("{} get unknown errror", getServiceName(), e);
+                    logger.error("{} get unknown error", getServiceName(), e);
                     try {
                         Thread.sleep(1000);
                     } catch (Throwable ignored) {