[ISSUE #8782] Fix log typo (#8783)

apache · Oct 5, 2024 · c5ac8a4 · c5ac8a4
1 parent 6eb5a10
commit c5ac8a4
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 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
@@ -799,7 +799,7 @@ public void executeRequestWhenWakeup(final Channel channel, final RemotingComman
                     }
                 }
             } 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
@@ -82,7 +82,7 @@ public V get(final long timeout) {
                         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
@@ -132,7 +132,7 @@ public void shutdown() {
         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
@@ -356,7 +356,7 @@ public void run() {
                     }
 
                 } catch (Exception e) {
-                    logger.error("{} get unknown errror", getServiceName(), e);
+                    logger.error("{} get unknown error", getServiceName(), e);
                     try {
                         Thread.sleep(1000);
                     } catch (Throwable ignored) {