From 92e6ee62852a53925e2402b79fd488cc99d4ebbb Mon Sep 17 00:00:00 2001 From: congqixia Date: Fri, 22 Nov 2024 10:06:33 +0800 Subject: [PATCH] enhance: Use load pool for `CreateTextIndex` (#37898) Related to #37895 Only resolves the starving issue which caused goroutine leakage Signed-off-by: Congqi Xia --- internal/querynodev2/segments/segment.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/querynodev2/segments/segment.go b/internal/querynodev2/segments/segment.go index 37544475f0..2d191896d6 100644 --- a/internal/querynodev2/segments/segment.go +++ b/internal/querynodev2/segments/segment.go @@ -1410,7 +1410,7 @@ func (s *LocalSegment) CreateTextIndex(ctx context.Context, fieldID int64) error var status C.CStatus log.Ctx(ctx).Info("create text index for segment", zap.Int64("segmentID", s.ID()), zap.Int64("fieldID", fieldID)) - GetDynamicPool().Submit(func() (any, error) { + GetLoadPool().Submit(func() (any, error) { status = C.CreateTextIndex(s.ptr, C.int64_t(fieldID)) return nil, nil }).Await()