diff --git a/server/ingester/flow_log/log_data/l7_flow_log.go b/server/ingester/flow_log/log_data/l7_flow_log.go index 5c94d324660..f0f09ca64be 100644 --- a/server/ingester/flow_log/log_data/l7_flow_log.go +++ b/server/ingester/flow_log/log_data/l7_flow_log.go @@ -21,6 +21,7 @@ import ( "encoding/hex" "fmt" "net" + "net/http" "time" "github.com/deepflowio/deepflow/server/ingester/config" @@ -558,7 +559,10 @@ func (h *L7FlowLog) fillExceptionDesc(l *pb.AppProtoLogsData) { code := l.Resp.Code switch datatype.L7Protocol(h.L7Protocol) { case datatype.L7_PROTOCOL_HTTP_1, datatype.L7_PROTOCOL_HTTP_2: - h.ResponseException = GetHTTPExceptionDesc(uint16(code)) + // only set exception message for HTTP status >= 400 + if code >= http.StatusBadRequest { + h.ResponseException = GetHTTPExceptionDesc(uint16(code)) + } case datatype.L7_PROTOCOL_DNS: h.ResponseException = GetDNSExceptionDesc(uint16(code)) case datatype.L7_PROTOCOL_DUBBO: