diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 97e0e3773dc..0f4df9b1a7d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -4198,8 +4198,7 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa String previousRSName = this.getLastFailedRSFromZK(region.getEncodedName()); Map maxSeqIdInStores = r.getMaxStoreSeqIdForLogReplay(); long minSeqIdForLogReplay = -1; - for (byte[] columnFamily : maxSeqIdInStores.keySet()) { - Long storeSeqIdForReplay = maxSeqIdInStores.get(columnFamily); + for (Long storeSeqIdForReplay : maxSeqIdInStores.values()) { if (minSeqIdForLogReplay == -1 || storeSeqIdForReplay < minSeqIdForLogReplay) { minSeqIdForLogReplay = storeSeqIdForReplay; }