Skip to content

Commit

Permalink
fix: disable kvs and vqueue initialization
Browse files Browse the repository at this point in the history
Signed-off-by: hlts2 <[email protected]>
  • Loading branch information
hlts2 committed Sep 9, 2024
1 parent 0500393 commit 9d1f550
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions pkg/agent/core/ngt/service/ngt.go
Original file line number Diff line number Diff line change
Expand Up @@ -1242,8 +1242,8 @@ func (n *ngt) RegenerateIndexes(ctx context.Context) (err error) {
if err != nil {
log.Errorf("failed to flushing vector to ngt index in delete kvs. error: %v", err)
}
n.kvs = nil
n.vq = nil
// n.kvs = nil
// n.vq = nil

// gc
runtime.GC()
Expand All @@ -1265,20 +1265,20 @@ func (n *ngt) RegenerateIndexes(ctx context.Context) (err error) {
}
}

nkvs := kvs.New(kvs.WithConcurrency(n.kvsdbConcurrency))

nvq, err := vqueue.New()
if err != nil {
log.Errorf("failed to create new vector vector queue. error: %v", err)
}
// nkvs := kvs.New(kvs.WithConcurrency(n.kvsdbConcurrency))
//
// nvq, err := vqueue.New()
// if err != nil {
// log.Errorf("failed to create new vector vector queue. error: %v", err)
// }

// renew instance
nn, err := newNGT(n.cfg, n.opts...)
if err != nil {
return err
}
nn.kvs = nkvs
nn.vq = nvq
// nn.kvs = nkvs
// nn.vq = nvq

// Regenerate with flags set
nn.flushing.Store(true)
Expand Down

0 comments on commit 9d1f550

Please sign in to comment.