opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
luozongle01
2024-10-05 10:09:07 +08:00
committed by RongtongJin
parent 278939a351
commit 2b3dde8f67
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
+1 -1
View File
@@ -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));
openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java
+1 -1
View File
@@ -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()) {
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
+1 -1
View File
@@ -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);
}
}
store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
+1 -1
View File
@@ -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) {