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 d0a28ed771c..9a6a81c1669 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 @@ -673,9 +673,9 @@ public class MemStoreFlusher implements FlushRequester { FlushType type = null; if (emergencyFlush) { type = isAboveHighWaterMark(); - if (type == null) { - type = isAboveLowWaterMark(); - } + } + if (type == null) { + type = isAboveLowWaterMark(); } for (FlushRequestListener listener : flushRequestListeners) { listener.flushRequested(type, region);