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
 		}