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 f12a90eeac..baa71e1bab 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -2889,7 +2889,7 @@ public class DefaultMessageStore implements MessageStore {
                     batchDispatchRequestQueue.poll();
                 }
             } catch (Exception e) {
-                LOGGER.warn(e.getMessage());
+                DefaultMessageStore.LOGGER.warn(this.getServiceName() + " service has exception. ", e);
             }
         }