diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
index 6d0730d76b6e..552f3440bde5 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
@@ -328,9 +328,8 @@ void clearWALEntryBatch() {
     while (this.isAlive() || this.entryReader.isAlive()) {
       try {
         if (EnvironmentEdgeManager.currentTime() >= timeout) {
-          LOG.warn(
-            "Shipper clearWALEntryBatch method timed out whilst waiting reader/shipper "
-              + "thread to stop. Not cleaning buffer usage. Shipper alive: {}; Reader alive: {}",
+          LOG.warn("Shipper clearWALEntryBatch method timed out while waiting reader/shipper "
+            + "thread to stop. Not cleaning buffer usage. PeerId: {}; Shipper alive: {}; Reader alive: {}",
             this.source.getPeerId(), this.isAlive(), this.entryReader.isAlive());
           return;
         } else {