Skip to content

Commit b63850a

Browse files
committed
HBASE-29698 Correct log message in ReplicationSourceShipper.clearWALEntryBatch
1 parent f800a13 commit b63850a

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -328,9 +328,8 @@ void clearWALEntryBatch() {
328328
while (this.isAlive() || this.entryReader.isAlive()) {
329329
try {
330330
if (EnvironmentEdgeManager.currentTime() >= timeout) {
331-
LOG.warn(
332-
"Shipper clearWALEntryBatch method timed out whilst waiting reader/shipper "
333-
+ "thread to stop. Not cleaning buffer usage. Shipper alive: {}; Reader alive: {}",
331+
LOG.warn("Shipper clearWALEntryBatch method timed out while waiting reader/shipper "
332+
+ "thread to stop. Not cleaning buffer usage. PeerId: {}; Shipper alive: {}; Reader alive: {}",
334333
this.source.getPeerId(), this.isAlive(), this.entryReader.isAlive());
335334
return;
336335
} else {

0 commit comments

Comments
 (0)