From 923f9dfdc26ab72f683f8ba9c36df77bc4ecc527 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Thu, 6 Nov 2025 20:36:50 +0800 Subject: [PATCH] fix: [2.6hf]Skip building text index for newly added columns (#45358) issue: #45315 master pr #45316 Signed-off-by: Cai Zhang --- internal/datanode/index/task_stats.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/datanode/index/task_stats.go b/internal/datanode/index/task_stats.go index a7b001afa0..a4bdfb091f 100644 --- a/internal/datanode/index/task_stats.go +++ b/internal/datanode/index/task_stats.go @@ -439,12 +439,12 @@ func (st *statsTask) createTextIndex(ctx context.Context, return binlog.GetFieldID() }) - getInsertFiles := func(fieldID int64) ([]string, error) { + getInsertFiles := func(fieldID int64, enableNull bool) ([]string, error) { if st.req.GetStorageVersion() == storage.StorageV2 { return []string{}, nil } binlogs, ok := fieldBinlogs[fieldID] - if !ok { + if !ok && !enableNull { return nil, fmt.Errorf("field binlog not found for field %d", fieldID) } result := make([]string, 0, len(binlogs)) @@ -469,7 +469,7 @@ func (st *statsTask) createTextIndex(ctx context.Context, } log.Info("field enable match, ready to create text index", zap.Int64("field id", field.GetFieldID())) // create text index and upload the text index files. - files, err := getInsertFiles(field.GetFieldID()) + files, err := getInsertFiles(field.GetFieldID(), field.GetNullable()) if err != nil { return err }