flush implicit writes in all paths in updateWriteEpoch

2021-07-02 11:09:36 +03:00 · 2021-07-02 11:09:36 +03:00 · a29947d47c
commit a29947d47c
parent be6cc2c3e6
1 changed files with 1 additions and 0 deletions
--- 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
 		}