diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java b/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java index 3a78bd4..5657ab1 100644 --- a/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java +++ b/src/main/java/org/apache/hadoop/hbase/regionserver/MemStore.java @@ -439,7 +439,7 @@ public class MemStore implements HeapSize { // to be extra safe we only remove Puts that have a memstoreTS==0 if (kv.getType() == KeyValue.Type.Put.getCode()) { // false means there was a change, so give us the size. - addedSize -= heapSizeChange(kv, false); + addedSize -= heapSizeChange(kv, true); it.remove(); }