From 2e81dff0eba03361a3f66931f18ec3e498b31ec9 Mon Sep 17 00:00:00 2001 From: Mike Davis Date: Wed, 6 Nov 2019 08:24:00 -0800 Subject: [PATCH] Fix ticker. --- pkg/event/processor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/event/processor.go b/pkg/event/processor.go index 043ec236f..af180eedb 100644 --- a/pkg/event/processor.go +++ b/pkg/event/processor.go @@ -173,7 +173,7 @@ func (p *BatchEventProcessor) startTicker(exeCtx utils.ExecutionCtx) { if p.Ticker != nil { return } - p.Ticker = time.NewTicker(p.FlushInterval * time.Millisecond) + p.Ticker = time.NewTicker(p.FlushInterval) wg := exeCtx.GetWaitSync() wg.Add(1) go func() {