Remove log record attribute data_stream.*

carsonip · Jan 16, 2024 · 4695926 · 4695926
1 parent 1f133b0
commit 4695926
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 12 deletions.
diff --git 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
@@ -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())