From 86cfdd5111f583f9edcfaed7020aedca0bbcb5fb Mon Sep 17 00:00:00 2001 From: Bo Du Date: Wed, 26 Feb 2020 17:40:48 -0500 Subject: [PATCH] Remove wg on builder. --- src/m3ninx/index/segment/builder/builder.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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