Auto multiline V2 - reuse cached message. Fixes panic in journald wit…

…h processing rules. (#33077)
DataDog · Jan 17, 2025 · 8163d0e · 8163d0e
1 parent 6ce5f00
commit 8163d0e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/logs/internal/decoder/auto_multiline_detection/aggregator.go b/pkg/logs/internal/decoder/auto_multiline_detection/aggregator.go
@@ -74,7 +74,9 @@ func (b *bucket) flush() *message.Message {
 		content = append(content, message.TruncatedFlag...)
 	}
 
-	msg := message.NewRawMessage(content, b.message.Status, b.originalDataLen, b.message.ParsingExtra.Timestamp)
+	msg := b.message
+	msg.SetContent(content)
+	msg.RawDataLen = b.originalDataLen
 	tlmTags := []string{"false", "single_line"}
 
 	if b.lineCount > 1 {