Fix log event.parent_id from otlp span event

elastic · Sep 27, 2024 · cf15f56 · cf15f56
1 parent 866967b
commit cf15f56
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/input/otlp/exceptions_test.go b/input/otlp/exceptions_test.go
@@ -60,10 +60,12 @@ func TestEncodeSpanEventsNonExceptions(t *testing.T) {
 		semconv.AttributeExceptionStacktrace, "stacktrace",
 	)
 
-	_, events := transformTransactionSpanEvents(t, "java", nonExceptionEvent, incompleteExceptionEvent)
+	transactionEvent, events := transformTransactionSpanEvents(t, "java", nonExceptionEvent, incompleteExceptionEvent)
 	require.Len(t, events, 2)
 	assert.Equal(t, modelpb.LogEventType, events[0].Type())
+	assert.Equal(t, transactionEvent.Transaction.Id, events[0].ParentId)
 	assert.Equal(t, modelpb.LogEventType, events[1].Type())
+	assert.Equal(t, transactionEvent.Transaction.Id, events[1].ParentId)
 }
 
 func TestEncodeSpanEventsJavaExceptions(t *testing.T) {

diff --git a/input/otlp/traces.go b/input/otlp/traces.go
@@ -1265,10 +1265,12 @@ func setLogContext(out *modelpb.APMEvent, parent *modelpb.APMEvent) {
 		out.Transaction.Id = parent.Transaction.Id
 		out.Span = &modelpb.Span{}
 		out.Span.Id = parent.Transaction.Id
+		out.ParentId = parent.Transaction.Id
 	}
 	if parent.Span != nil {
 		out.Span = &modelpb.Span{}
 		out.Span.Id = parent.Span.Id
+		out.ParentId = parent.Span.Id
 	}
 }