Skip to content

Commit

Permalink
Fix ticker memory leak in bulk indexer due to internal flush call res…
Browse files Browse the repository at this point in the history
…etting the ticker. (#797)
  • Loading branch information
tblyler authored and Anaethelion committed Feb 7, 2024
1 parent e5c27bc commit 266a2a6
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion esutil/bulk_indexer.go
Original file line number Diff line number Diff line change
Expand Up @@ -402,8 +402,8 @@ func (w *worker) run() {
w.bi.config.DebugLogger.Printf("[worker-%03d] Started\n", w.id)
}
defer func() {
w.ticker.Stop()
w.flush(ctx)
w.ticker.Stop()
w.bi.wg.Done()
}()

Expand Down

0 comments on commit 266a2a6

Please sign in to comment.