diff --git a/app/vmselect/netstorage/netstorage.go b/app/vmselect/netstorage/netstorage.go index 7aa6e2974..a756635c5 100644 --- a/app/vmselect/netstorage/netstorage.go +++ b/app/vmselect/netstorage/netstorage.go @@ -684,9 +684,11 @@ func (pts *packedTimeseries) unpackUpdateAddrs(tbfs []*tmpBlocksFile, tr storage } // Spread work among worker channels. - for i, upws := range upwss { - idx := i % len(workChs) + i := 0 + for _, upws := range upwss { for _, upw := range upws { + idx := i % len(workChs) + i++ workChs[idx] <- upw } }