We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e9ee9dc commit 0b433a8Copy full SHA for 0b433a8
1 file changed
store/store.go
@@ -320,6 +320,10 @@ func (s *Store) Partition() {
320
if fe := sc.db.Flatten(32); fe != nil {
321
return ErrGarbageCollectDB(fe)
322
}
323
+ // call db.Sync() to sync both the logs, the active memtable's WAL and the vLog
324
+ if se := sc.db.Sync(); se != nil {
325
+ return ErrGarbageCollectDB(se)
326
+ }
327
// unset isGarbageCollecting once complete
328
defer s.isGarbageCollecting.Store(false)
329
// trigger garbage collector to prune keys
0 commit comments