diff --git src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index eaa02d1..a441bb5 100644 --- src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -3108,9 +3108,10 @@ public class HRegion implements HeapSize { // , Writable{ for (Map.Entry> e : familyMap.entrySet()) { byte[] family = e.getKey(); List edits = e.getValue(); - Store store = getStore(family); - for (KeyValue kv: edits) { + int listSize = edits.size(); + for (int i=0; i< listSize; i++) { + KeyValue kv = edits.get(i); kv.setMemstoreTS(localizedWriteEntry.getWriteNumber()); size += store.add(kv); }