diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java index 699c9b6b0e..34c7b5d27a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java @@ -707,6 +707,7 @@ class MemStoreFlusher implements FlushRequester { boolean blocked = false; long startTime = 0; boolean interrupted = false; + boolean doLogBlocked = false; try { flushType = isAboveHighWaterMark(); while (flushType != FlushType.NORMAL && !server.isStopped()) { @@ -744,11 +745,14 @@ class MemStoreFlusher implements FlushRequester { LOG.warn("Interrupted while waiting"); interrupted = true; } - long took = EnvironmentEdgeManager.currentTime() - start; - LOG.warn("Memstore is above high water mark and block " + took + "ms"); + doLogBlocked = true; flushType = isAboveHighWaterMark(); } } finally { + if (doLogBlocked) { + long took = EnvironmentEdgeManager.currentTime() - start; + LOG.warn("Memstore is above high water mark and block " + took + "ms"); + } if (interrupted) { Thread.currentThread().interrupt(); }