Skip to content

Commit b21a57d

Browse files
authored
fix(collector) add nil check before consuming traces in telemetryAPIReceiver (#2241)
1 parent 3fd95aa commit b21a57d

1 file changed

Lines changed: 8 additions & 6 deletions

File tree

collector/receiver/telemetryapireceiver/receiver.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -266,12 +266,14 @@ func (r *telemetryAPIReceiver) httpHandler(w http.ResponseWriter, req *http.Requ
266266
if len(r.lastPlatformStartTime) > 0 && len(r.lastPlatformEndTime) > 0 {
267267
if record, ok := el.Record.(map[string]any); ok {
268268
if td, err := r.createPlatformInitSpan(record, r.lastPlatformStartTime, r.lastPlatformEndTime); err == nil {
269-
err := r.nextTraces.ConsumeTraces(context.Background(), td)
270-
if err == nil {
271-
r.lastPlatformEndTime = ""
272-
r.lastPlatformStartTime = ""
273-
} else {
274-
r.logger.Error("error receiving traces", zap.Error(err))
269+
if r.nextTraces != nil {
270+
err := r.nextTraces.ConsumeTraces(context.Background(), td)
271+
if err == nil {
272+
r.lastPlatformEndTime = ""
273+
r.lastPlatformStartTime = ""
274+
} else {
275+
r.logger.Error("error receiving traces", zap.Error(err))
276+
}
275277
}
276278
}
277279
}

0 commit comments

Comments
 (0)