diff --git a/server/wal/wal.go b/server/wal/wal.go index 37f6dd136..68303cd3a 100644 --- a/server/wal/wal.go +++ b/server/wal/wal.go @@ -783,14 +783,16 @@ func (w *WAL) cut() error { } func (w *WAL) sync() error { - if w.unsafeNoSync { - return nil - } if w.encoder != nil { if err := w.encoder.flush(); err != nil { return err } } + + if w.unsafeNoSync { + return nil + } + start := time.Now() err := fileutil.Fdatasync(w.tail().File)