diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java index 2523215..b15f150 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java @@ -871,7 +871,7 @@ public class FSHLog implements WAL { for (Map.Entry e: regionsSequenceNums.entrySet()) { ConcurrentMap m = this.oldestUnflushedStoreSequenceIds.get(e.getKey()); - if (m == null) { + if (m == null || m.isEmpty()) { continue; } long unFlushedVal = Collections.min(m.values());