We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4886229 commit 80249b4Copy full SHA for 80249b4
pkg/ingester/transfer.go
@@ -231,7 +231,8 @@ func (i *Ingester) TransferChunks(stream client.Ingester_TransferChunksServer) e
231
xfer := func() error {
232
userStates := newUserStates(i.limiter, i.cfg, i.metrics)
233
234
- fromIngesterID, seriesReceived, err := i.acceptChunksFromStream(acceptChunksOptions{
+ var err error
235
+ fromIngesterID, seriesReceived, err = i.acceptChunksFromStream(acceptChunksOptions{
236
States: userStates,
237
Stream: stream,
238
ValidateRemoteLeaving: true,
0 commit comments