From 6db64ab323e967e2fdd408765bbeb973a803d47f Mon Sep 17 00:00:00 2001 From: Steffen Siering Date: Mon, 10 Apr 2017 09:55:32 +0200 Subject: [PATCH] Downgrade ES bulk item log message (#3959) Downgrade logging of per bulk item failures from INFO to DEBUG. In worst case, every item in a bulk might fail, poluting the logs with loads of similar messages (one log messages per `bulk_max_size`). (cherry picked from commit 58bd0e16954f374f0104bf5a1e725952e5189b85) --- CHANGELOG.asciidoc | 1 + libbeat/outputs/elasticsearch/client.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc index a0767a8aabc1..c1aed1838925 100644 --- a/CHANGELOG.asciidoc +++ b/CHANGELOG.asciidoc @@ -118,6 +118,7 @@ https://github.com/elastic/beats/compare/v5.2.2...v5.3.0[View commits] - Add `_id`, `_type`, `_index` and `_score` fields in the generated index pattern. {pull}3282[3282] - Fix potential elasticsearch output URL parsing error if protocol scheme is missing. {pull}3671[3671] - Improve error message when downloading the dashboards fails. {pull}3805[3805] +- Downgrade Elasticsearch per batch item failure log to debug level. {issue}3953[3953] *Filebeat* diff --git a/libbeat/outputs/elasticsearch/client.go b/libbeat/outputs/elasticsearch/client.go index fb53519f0485..bd2a027c72d2 100644 --- a/libbeat/outputs/elasticsearch/client.go +++ b/libbeat/outputs/elasticsearch/client.go @@ -443,7 +443,7 @@ func bulkCollectPublishFails( continue } - logp.Info("Bulk item insert failed (i=%v, status=%v): %s", i, status, msg) + debugf("Bulk item insert failed (i=%v, status=%v): %s", i, status, msg) failed = append(failed, data[i]) }