diff --git a/src/m3ninx/index/segment/builder/builder.go b/src/m3ninx/index/segment/builder/builder.go index d5c2fb71c4..891b28e7c8 100644 --- a/src/m3ninx/index/segment/builder/builder.go +++ b/src/m3ninx/index/segment/builder/builder.go @@ -67,7 +67,6 @@ type builder struct { fields *shardedFieldsMap uniqueFields [][][]byte - wg sync.WaitGroup indexQueues []chan indexJob closed *atomic.Bool } @@ -199,7 +198,7 @@ func (b *builder) InsertBatch(batch index.Batch) error { } // Wait for all the concurrent indexing jobs to finish. - b.wg.Wait() + wg.Wait() if !batchErr.IsEmpty() { return batchErr