diff --git a/processor/tailsamplingprocessor/processor.go b/processor/tailsamplingprocessor/processor.go index e2a65a6cde46..e993212e85d7 100644 --- a/processor/tailsamplingprocessor/processor.go +++ b/processor/tailsamplingprocessor/processor.go @@ -283,7 +283,7 @@ func (tsp *tailSamplingSpanProcessor) loadSamplingPolicy(cfgs []PolicyCfg) error func (tsp *tailSamplingSpanProcessor) SetSamplingPolicy(cfgs []PolicyCfg) { tsp.logger.Debug("Setting pending sampling policy", zap.Int("pending.len", len(cfgs))) - + tsp.setPolicyMux.Lock() defer tsp.setPolicyMux.Unlock()