diff --git a/pkg/ingester/transfer.go b/pkg/ingester/transfer.go index a249ef2a0b275190d69aa6a98698e3daeeb766ac..ab3f1398990da679b64669deafe8e879523f59bf 100644 --- a/pkg/ingester/transfer.go +++ b/pkg/ingester/transfer.go @@ -10,6 +10,7 @@ import ( "github.com/cortexproject/cortex/pkg/ring" "github.com/cortexproject/cortex/pkg/util" "github.com/go-kit/kit/log/level" + "github.com/grafana/loki/pkg/helpers" "github.com/grafana/loki/pkg/logproto" "github.com/pkg/errors" "github.com/prometheus/client_golang/prometheus" @@ -159,7 +160,7 @@ func (i *Ingester) transferOut(ctx context.Context) error { return err } if c, ok := c.(io.Closer); ok { - defer c.Close() + defer helpers.LogError("closing client", c.Close) } ic := c.(logproto.IngesterClient)