diff --git a/pkg/file/redundancy/getter/getter.go b/pkg/file/redundancy/getter/getter.go index f027cdf6a65..358618041cc 100644 --- a/pkg/file/redundancy/getter/getter.go +++ b/pkg/file/redundancy/getter/getter.go @@ -151,8 +151,8 @@ func (g *decoder) fetch(ctx context.Context, i int, waitForRecovery bool) (err e } g.setData(i, ch.Data()) - close(g.waits[i]) g.fetchedCnt.Add(1) + close(g.waits[i]) return nil }