From 4695926cbef211b817ce127d551cb48147d304dc Mon Sep 17 00:00:00 2001 From: Carson Ip Date: Tue, 16 Jan 2024 10:50:29 +0000 Subject: [PATCH] Remove log record attribute data_stream.* --- input/otlp/logs.go | 10 ---------- input/otlp/logs_test.go | 2 -- 2 files changed, 12 deletions(-) diff --git a/input/otlp/logs.go b/input/otlp/logs.go index 5637265b..8906dcbb 100644 --- a/input/otlp/logs.go +++ b/input/otlp/logs.go @@ -182,16 +182,6 @@ func (c *Consumer) convertLogRecord( event.Network.Connection = modelpb.NetworkConnectionFromVTPool() } event.Network.Connection.Type = v.Str() - case attributeDataStreamDataset: - if event.DataStream == nil { - event.DataStream = modelpb.DataStreamFromVTPool() - } - event.DataStream.Dataset = v.Str() - case attributeDataStreamNamespace: - if event.DataStream == nil { - event.DataStream = modelpb.DataStreamFromVTPool() - } - event.DataStream.Namespace = v.Str() default: setLabel(replaceDots(k), event, ifaceAttributeValue(v)) } diff --git a/input/otlp/logs_test.go b/input/otlp/logs_test.go index 755dcc53..c48acb78 100644 --- a/input/otlp/logs_test.go +++ b/input/otlp/logs_test.go @@ -442,8 +442,6 @@ func TestConsumerConsumeOTelEventLogs(t *testing.T) { record1 := newLogRecord("") // no log body record1.Attributes().PutStr("event.domain", "device") record1.Attributes().PutStr("event.name", "MyEvent") - record1.Attributes().PutStr("data_stream.dataset", "dataset") - record1.Attributes().PutStr("data_stream.namespace", "namespace") record1.CopyTo(scopeLogs.LogRecords().AppendEmpty())