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 Feb 7, 2024
1 parent a58e89f commit dde3be0
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 dde3be0

Please sign in to comment.