diff --git a/blockstore/splitstore/splitstore.go b/blockstore/splitstore/splitstore.go index 9b2ae8e20..b41a90ecb 100644 --- a/blockstore/splitstore/splitstore.go +++ b/blockstore/splitstore/splitstore.go @@ -623,6 +623,7 @@ func (s *SplitStore) updateWriteEpoch() { if dt < 0 { writeEpoch := curTs.Height() + 1 if writeEpoch > s.writeEpoch { + s.flushImplicitWrites(true) s.writeEpoch = writeEpoch }