diff --git a/collector/processor/concurrentbatchprocessor/batch_processor.go b/collector/processor/concurrentbatchprocessor/batch_processor.go index 7cf1c647b7..5a018596d5 100644 --- a/collector/processor/concurrentbatchprocessor/batch_processor.go +++ b/collector/processor/concurrentbatchprocessor/batch_processor.go @@ -374,8 +374,7 @@ func (b *shard) sendItems(trigger trigger) { } else { var sp trace.Span links := buildLinks(contexts) - parent = context.Background() - parent, sp = b.tracer.Tracer("otel").Start(context.Background(), "concurrent_batch_processor/export", trace.WithLinks(links...)) + parent, sp = b.tracer.Tracer("otel").Start(b.exportCtx, "concurrent_batch_processor/export", trace.WithLinks(links...)) sp.End() } err = b.batch.export(parent, req)