diff --git a/app/vmagent/remotewrite/remotewrite.go b/app/vmagent/remotewrite/remotewrite.go index 9f0dedc1a..1a0fb8376 100644 --- a/app/vmagent/remotewrite/remotewrite.go +++ b/app/vmagent/remotewrite/remotewrite.go @@ -116,8 +116,8 @@ func Push(wr *prompbmarshal.WriteRequest) { tssBlock = rctx.applyRelabeling(tssBlock) idx := atomic.AddUint64(&pssNextIdx, 1) % uint64(len(pss)) pss[idx].Push(tssBlock) + rctx.reset() } - rctx.reset() relabelCtxPool.Put(rctx) }