diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/IPCLoggerChannel.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/IPCLoggerChannel.java index 324747618ae..3a882e5e61b 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/IPCLoggerChannel.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/IPCLoggerChannel.java @@ -492,6 +492,10 @@ public class IPCLoggerChannel implements AsyncLogger { Preconditions.checkArgument(size >= 0); if (queuedEditsSizeBytes + size > queueSizeLimitBytes && queuedEditsSizeBytes > 0) { + QuorumJournalManager.LOG.warn("Pending edits to " + IPCLoggerChannel.this + + " is going to exceed limit size: " + queueSizeLimitBytes + + ", current queued edits size: " + queuedEditsSizeBytes + + ", will silently drop " + size + " bytes of edits!"); throw new LoggerTooFarBehindException(); } queuedEditsSizeBytes += size;