vlinsert: return JSON arena back to the pool in case of an error (#860)

vadimalekseev · web-flow · commit c57bc52e774e · 2025-12-05T14:22:10.000+07:00
diff --git a/app/vlinsert/opentelemetry/pb.go b/app/vlinsert/opentelemetry/pb.go
@@ -365,6 +365,7 @@ func decodeAnyValue(src []byte, fs *logstorage.Fields, fb *fmtBuffer, fieldName
 			// Encode arrays as JSON to match the behavior of /insert/jsonline
 			arr, err := decodeArrayValueToJSON(data, a, fb)
 			if err != nil {
+				jsonArenaPool.Put(a)
 				return fmt.Errorf("cannot decode ArrayValue: %w", err)
 			}
 			encodedArr := fb.encodeJSONValue(arr)

Original file line number	Diff line number	Diff line change
`@@ -365,6 +365,7 @@ func decodeAnyValue(src []byte, fs logstorage.Fields, fb fmtBuffer, fieldName`
`365`	`365`	`// Encode arrays as JSON to match the behavior of /insert/jsonline`
`366`	`366`	`arr, err := decodeArrayValueToJSON(data, a, fb)`
`367`	`367`	`if err != nil {`
	`368`	`+ jsonArenaPool.Put(a)`
`368`	`369`	`return fmt.Errorf("cannot decode ArrayValue: %w", err)`
`369`	`370`	`}`
`370`	`371`	`encodedArr := fb.encodeJSONValue(arr)`