diff --git a/exporter/exporterhelper/internal/queue_sender.go b/exporter/exporterhelper/internal/queue_sender.go index 116ced2d598..c9084839d61 100644 --- a/exporter/exporterhelper/internal/queue_sender.go +++ b/exporter/exporterhelper/internal/queue_sender.go @@ -140,6 +140,7 @@ func (qs *QueueSender) Shutdown(ctx context.Context) error { for _, callback := range qs.shutdownCallbacks { callback() } + qs.shutdownCallbacks = nil if err := qs.queue.Shutdown(ctx); err != nil { return err