diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index 87ebebb..bddb5f5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -3793,9 +3796,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver { // // Once we are over the limit, restoreEdit will keep returning true to // flush -- but don't flush until we've played all the kvs that make up // the WALEdit. - if (!flush) { - flush = restoreEdit(store, cell); - } + flush = restoreEdit(store, cell); editsCount++; }