From e66c115997bfafec4d50d02ce0a772e7703fe324 Mon Sep 17 00:00:00 2001 From: chengwenxi Date: Wed, 26 Jun 2019 16:52:20 +0800 Subject: [PATCH] Flush wal on stop --- consensus/wal.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consensus/wal.go b/consensus/wal.go index d56ede26d23..26428a4c626 100644 --- a/consensus/wal.go +++ b/consensus/wal.go @@ -116,6 +116,7 @@ func (wal *baseWAL) OnStart() error { // Use Wait() to ensure it's finished shutting down // before cleaning up files. func (wal *baseWAL) OnStop() { + wal.group.Flush() wal.group.Stop() wal.group.Close() }