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 648a415d441..bc11bce4c18 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 @@ -920,7 +920,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi this.mvcc.advanceTo(maxSeqId); } finally { // update the stores that we are done replaying - stores.forEach(HStore::startReplayingFromWAL); + stores.forEach(HStore::stopReplayingFromWAL); } } this.lastReplayedOpenRegionSeqId = maxSeqId;