Release 1.15 (#5423)

* Do not reuse remote write requests in case of error (#5422)

* Do not reuse remote write requests in case of error

Signed-off-by: Alan Protasio <[email protected]>

* Changelog

Signed-off-by: Alan Protasio <[email protected]>

---------

Signed-off-by: Alan Protasio <[email protected]>

* Release and bump version to 1.15.3

Signed-off-by: Alan Protasio <[email protected]>

* Fix Changelog

Signed-off-by: Alan Protasio <[email protected]>

---------

Signed-off-by: Alan Protasio <[email protected]>

Author: alanprot

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 ## master / unreleased
 
+## 1.15.3 2023-06-22
+
+* [BUGFIX] Distributor: Fix potential data corruption in cases of timeout between distributors and ingesters. #5422
+
 ## 1.15.2 2023-05-09
 
 * [ENHANCEMENT] Update Go version to 1.20.4. #5299

VERSION

@@ -1 +1 @@
-1.15.2
+1.15.3

pkg/distributor/distributor.go

@@ -843,7 +843,12 @@ func (d *Distributor) send(ctx context.Context, ingester ring.InstanceDesc, time
 	req.Source = source
 
 	_, err = c.PushPreAlloc(ctx, req)
-	cortexpb.ReuseWriteRequest(req)
+
+	// We should not reuse the req in case of errors:
+	// See: https://github.com/grpc/grpc-go/issues/6355
+	if err == nil {
+		cortexpb.ReuseWriteRequest(req)
+	}
 
 	if len(metadata) > 0 {
 		d.ingesterAppends.WithLabelValues(ingester.Addr, typeMetadata).Inc()