fix: applicaition log decode failed causes subsequent data anomalies

deepflowio · Sep 20, 2024 · d10b0ef · d10b0ef
1 parent 417f578
commit d10b0ef
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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 {