Skip to content

Commit 0c7a4f2

Browse files
liuxiaocs7Apache9
authored andcommitted
HBASE-29698 Correct log message in ReplicationSourceShipper.clearWALEntryBatch (#7431)
Signed-off-by: Duo Zhang <[email protected]> (cherry picked from commit 100cd23)
1 parent d481a46 commit 0c7a4f2

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -343,10 +343,9 @@ void clearWALEntryBatch() {
343343
while (this.isAlive() || this.entryReader.isAlive()) {
344344
try {
345345
if (EnvironmentEdgeManager.currentTime() >= timeout) {
346-
LOG.warn(
347-
"Shipper clearWALEntryBatch method timed out whilst waiting reader/shipper "
348-
+ "thread to stop. Not cleaning buffer usage. Shipper alive: {}; Reader alive: {}",
349-
this.source.getPeerId(), this.isAlive(), this.entryReader.isAlive());
346+
LOG.warn("Shipper clearWALEntryBatch method timed out while waiting reader/shipper "
347+
+ "thread to stop. Not cleaning buffer usage. PeerId: {}; Shipper alive: {}; Reader "
348+
+ "alive: {}", this.source.getPeerId(), this.isAlive(), this.entryReader.isAlive());
350349
return;
351350
} else {
352351
// Wait both shipper and reader threads to stop

0 commit comments

Comments
 (0)