From 9aae7b681a633a50ff6f42e78f08df8926f6539f Mon Sep 17 00:00:00 2001 From: simitt Date: Tue, 8 Dec 2020 20:42:38 +0100 Subject: [PATCH] fix timestamp --- systemtest/apmservertest/server.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/systemtest/apmservertest/server.go b/systemtest/apmservertest/server.go index 93ed399a7c5..5882a222539 100644 --- a/systemtest/apmservertest/server.go +++ b/systemtest/apmservertest/server.go @@ -288,7 +288,7 @@ func (s *Server) consumeStderr(procStderr io.Reader) { s.Stderr = stderrPipeReader type logEntry struct { - Timestamp logpTimestamp `json:"timestamp"` + Timestamp logpTimestamp `json:"@timestamp"` Message string `json:"message"` Level zapcore.Level `json:"log.level"` Logger string `json:"log.logger"` @@ -312,7 +312,7 @@ func (s *Server) consumeStderr(procStderr io.Reader) { if err := json.Unmarshal(raw, &fields); err != nil { break } - delete(fields, "timestamp") + delete(fields, "@timestamp") delete(fields, "log.level") delete(fields, "log.logger") delete(fields, "log.origin")