diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index d76b634051..4cbcdd2b93 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -1168,7 +1168,7 @@ func (s *shards) sendSamplesWithBackoff(ctx context.Context, samples []prompb.Ti return err } - reqSize := len(*buf) + reqSize := len(req) *buf = req // An anonymous function allows us to defer the completion of our per-try spans @@ -1264,7 +1264,6 @@ func sendWriteRequestWithBackoff(ctx context.Context, cfg config.QueueConfig, l } try++ - continue } }