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 53545ed..b615728 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 @@ -864,7 +864,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.size() == 0) { continue; } long unFlushedVal = Collections.min(m.values());