From 7d7cb836af47b564dbc47c90b6203a98802585bb Mon Sep 17 00:00:00 2001 From: kevin Date: Fri, 6 Nov 2020 12:25:48 +0800 Subject: [PATCH] fix issue #186 --- core/executors/periodicalexecutor.go | 1 + 1 file changed, 1 insertion(+) diff --git a/core/executors/periodicalexecutor.go b/core/executors/periodicalexecutor.go index 98bb7cb5..aaf2a6d8 100644 --- a/core/executors/periodicalexecutor.go +++ b/core/executors/periodicalexecutor.go @@ -82,6 +82,7 @@ func (pe *PeriodicalExecutor) Sync(fn func()) { } func (pe *PeriodicalExecutor) Wait() { + pe.Flush() pe.wgBarrier.Guard(func() { pe.waitGroup.Wait() })