From 03b63bf982dfdc16ca22c61926f794d35e83f7cd Mon Sep 17 00:00:00 2001 From: Buqian Zheng Date: Wed, 19 Mar 2025 10:50:14 +0800 Subject: [PATCH] fix: use NewInsertDataWithFunctionOutputField when importing binlog file (#40741) issue: https://github.com/milvus-io/milvus/issues/40740 Signed-off-by: Buqian Zheng --- internal/util/importutilv2/binlog/reader.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/util/importutilv2/binlog/reader.go b/internal/util/importutilv2/binlog/reader.go index 967fae99aa..6cbf19b8ce 100644 --- a/internal/util/importutilv2/binlog/reader.go +++ b/internal/util/importutilv2/binlog/reader.go @@ -138,7 +138,7 @@ func (r *reader) readDelete(deltaLogs []string, tsStart, tsEnd uint64) (*storage } func (r *reader) Read() (*storage.InsertData, error) { - insertData, err := storage.NewInsertData(r.schema) + insertData, err := storage.NewInsertDataWithFunctionOutputField(r.schema) if err != nil { return nil, err } @@ -192,7 +192,7 @@ OUTER: if len(masks) == 0 { // no data will undergo filtration, return directly return insertData, nil } - result, err := storage.NewInsertData(r.schema) + result, err := storage.NewInsertDataWithFunctionOutputField(r.schema) if err != nil { return nil, err }