diff --git a/receiver/signalfxreceiver/receiver.go b/receiver/signalfxreceiver/receiver.go index df023f007bda..088f23e8462e 100644 --- a/receiver/signalfxreceiver/receiver.go +++ b/receiver/signalfxreceiver/receiver.go @@ -155,7 +155,7 @@ func (r *sfxReceiver) Shutdown() error { func (r *sfxReceiver) handleReq(resp http.ResponseWriter, req *http.Request) { ctx := obsreport.ReceiverContext(req.Context(), r.config.Name(), "http", r.config.Name()) - ctx = obsreport.StartTraceDataReceiveOp(ctx, r.config.Name(), "http") + ctx = obsreport.StartMetricsReceiveOp(ctx, r.config.Name(), "http") if req.Method != http.MethodPost { r.failRequest(ctx, resp, http.StatusBadRequest, invalidMethodRespBody, nil) @@ -255,6 +255,7 @@ func (r *sfxReceiver) failRequest( traceStatus.Message = err.Error() } reqSpan.SetStatus(traceStatus) + reqSpan.End() r.logger.Debug( "SignalFx receiver request failed", diff --git a/testbed/tests/metric_test.go b/testbed/tests/metric_test.go index f8863d559793..913668b80fcc 100644 --- a/testbed/tests/metric_test.go +++ b/testbed/tests/metric_test.go @@ -43,7 +43,7 @@ func TestMetric10kDPS(t *testing.T) { NewCarbonDataReceiver(testbed.GetAvailablePort(t)), testbed.ResourceSpec{ ExpectedMaxCPU: 115, - ExpectedMaxRAM: 60, + ExpectedMaxRAM: 65, }, }, {