diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java index 112e9bced4..05ea526c99 100644 --- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java @@ -1228,7 +1228,7 @@ public class CommitLog { try { Thread.sleep(10); } catch (InterruptedException e) { - CommitLog.log.warn("GroupCommitService Exception, ", e); + CommitLog.log.warn(this.getServiceName() + " Exception, ", e); } synchronized (this) { diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index ed882aa681..1f24dc7771 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -924,7 +924,7 @@ public class DefaultMessageStore implements MessageStore { @Override public void executeDeleteFilesManually() { - this.cleanCommitLogService.excuteDeleteFilesManualy(); + this.cleanCommitLogService.executeDeleteFilesManually(); } @Override @@ -1590,7 +1590,7 @@ public class DefaultMessageStore implements MessageStore { private volatile boolean cleanImmediately = false; - public void excuteDeleteFilesManualy() { + public void executeDeleteFilesManually() { this.manualDeleteFileSeveralTimes = MAX_MANUAL_DELETE_FILE_TIMES; DefaultMessageStore.log.info("executeDeleteFilesManually was invoked"); }