From 4b7e6b36cec535cd40135262966a24b5461a3744 Mon Sep 17 00:00:00 2001 From: Khanh Quoc Le Date: Fri, 17 Nov 2023 21:58:52 +0700 Subject: [PATCH] Add _stream fields log (#5068) --- app/vlinsert/elasticsearch/elasticsearch.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/vlinsert/elasticsearch/elasticsearch.go b/app/vlinsert/elasticsearch/elasticsearch.go index a7fb24823..8d5c03e12 100644 --- a/app/vlinsert/elasticsearch/elasticsearch.go +++ b/app/vlinsert/elasticsearch/elasticsearch.go @@ -105,7 +105,7 @@ func RequestHandler(path string, w http.ResponseWriter, r *http.Request) bool { vlstorage.MustAddRows(lr) logstorage.PutLogRows(lr) if err != nil { - logger.Warnf("cannot decode log message #%d in /_bulk request: %s", n, err) + logger.Warnf("cannot decode log message #%d in /_bulk request: %s, stream fields: %s", n, err, cp.StreamFields) return true }