diff --git a/pkg/query-service/app/http_handler.go b/pkg/query-service/app/http_handler.go index 5267ac49d3..06d57603ec 100644 --- a/pkg/query-service/app/http_handler.go +++ b/pkg/query-service/app/http_handler.go @@ -3128,7 +3128,7 @@ func (aH *APIHandler) liveTailLogs(w http.ResponseWriter, r *http.Request) { var buf bytes.Buffer enc := json.NewEncoder(&buf) enc.Encode(log) - fmt.Fprintf(w, "event: log\ndata: %v\n\n", buf.String()) + fmt.Fprintf(w, "data: %v\n\n", buf.String()) flusher.Flush() case <-client.Done: zap.S().Debug("done!")