diff --git a/processor/tailsamplingprocessor/processor.go b/processor/tailsamplingprocessor/processor.go index 7d93f22c4fbae..86e9d955c566f 100644 --- a/processor/tailsamplingprocessor/processor.go +++ b/processor/tailsamplingprocessor/processor.go @@ -185,9 +185,9 @@ func (tsp *tailSamplingSpanProcessor) samplingPolicyOnTick() { // Sampled or not, remove the batches trace.Lock() - allSpans := ptrace.NewTraces() + allSpans := trace.ReceivedBatches trace.FinalDecision = decision - trace.ReceivedBatches.MoveTo(allSpans) + trace.ReceivedBatches = ptrace.NewTraces() trace.Unlock() if decision == sampling.Sampled {