diff --git a/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
index 3a5b78eb3f71bbb745f22a5a603c3370c9f118df..2122211d53b8cfd82b88c453e19a0200e468eee3 100644
--- a/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java
@@ -275,6 +275,7 @@ public class DLegerCommitLog extends CommitLog {
         return beginTimeInDlegerLock;
     }
 
+    @Override
     public PutMessageResult putMessage(final MessageExtBrokerInner msg) {
         // Set the storage time
         msg.setStoreTimestamp(System.currentTimeMillis());
@@ -415,6 +416,7 @@ public class DLegerCommitLog extends CommitLog {
 
     }
 
+    @Override
     public PutMessageResult putMessages(final MessageExtBatch messageExtBatch) {
         return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
     }