Skip to content

Commit

Permalink
Fix ticker.
Browse files Browse the repository at this point in the history
  • Loading branch information
Mike Davis committed Nov 6, 2019
1 parent 2a45835 commit 2e81dff
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/event/processor.go
Expand Up @@ -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() {
Expand Down

0 comments on commit 2e81dff

Please sign in to comment.