From d10b0ef756cecca52accc4516bccaf0c85708e31 Mon Sep 17 00:00:00 2001 From: zhuofeng Date: Fri, 20 Sep 2024 16:35:15 +0800 Subject: [PATCH] fix: applicaition log decode failed causes subsequent data anomalies --- server/ingester/app_log/decoder/decoder.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/server/ingester/app_log/decoder/decoder.go b/server/ingester/app_log/decoder/decoder.go index c7a6d8e6d83..dff10c393ab 100644 --- a/server/ingester/app_log/decoder/decoder.go +++ b/server/ingester/app_log/decoder/decoder.go @@ -483,10 +483,9 @@ func (d *Decoder) handleAppLog(agentId uint16, decoder *codec.SimpleDecoder) { err := json.UnmarshalString(utils.String(bytes), &d.appLogEntrysCache) if err != nil { if d.counter.ErrorCount == 0 { - log.Errorf("application log json decode failed: %s", err) + log.Errorf("application log (%s) json decode (%d) failed: %s", utils.String(bytes), len(d.appLogEntrysCache), err) } d.counter.ErrorCount++ - return } for i, appLogEntry := range d.appLogEntrysCache { if err := d.WriteAppLog(agentId, &appLogEntry); err != nil {