diff --git a/collector/receiver/telemetryapireceiver/receiver.go b/collector/receiver/telemetryapireceiver/receiver.go index 4008657a62..231c3cc457 100644 --- a/collector/receiver/telemetryapireceiver/receiver.go +++ b/collector/receiver/telemetryapireceiver/receiver.go @@ -223,7 +223,7 @@ func (r *telemetryAPIReceiver) createLogs(slice []telemetryapi.Event) (plog.Logs } } if level, ok := record["level"].(string); ok { - logRecord.SetSeverityNumber(severityTextToNumber(level)) + logRecord.SetSeverityNumber(severityTextToNumber(strings.ToUpper(level))) logRecord.SetSeverityText(logRecord.SeverityNumber().String()) } if requestId, ok := record["requestId"].(string); ok { @@ -275,6 +275,7 @@ func severityTextToNumber(severityText string) plog.SeverityNumber { "FATAL4": plog.SeverityNumberFatal4, "CRITICAL": plog.SeverityNumberFatal, "ALL": plog.SeverityNumberTrace, + "WARNING": plog.SeverityNumberWarn, } if ans, ok := mapping[strings.ToUpper(severityText)]; ok { return ans diff --git a/collector/receiver/telemetryapireceiver/receiver_test.go b/collector/receiver/telemetryapireceiver/receiver_test.go index ea23068970..ac2a0349e4 100644 --- a/collector/receiver/telemetryapireceiver/receiver_test.go +++ b/collector/receiver/telemetryapireceiver/receiver_test.go @@ -456,6 +456,10 @@ func TestSeverityTextToNumber(t *testing.T) { level: "ALL", number: plog.SeverityNumberTrace, }, + { + level: "WARNING", + number: plog.SeverityNumberWarn, + }, { level: "UNKNOWN", number: plog.SeverityNumberUnspecified,