From f82e56fbba088c23f550827e95c1fff0a8b2cf4c Mon Sep 17 00:00:00 2001 From: sniper Date: Wed, 3 Nov 2021 17:10:31 +0800 Subject: [PATCH] fix request bytes size and continue is useless (#9635) Signed-off-by: kalmanzhao Co-authored-by: kalmanzhao --- storage/remote/queue_manager.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 } }