From 6eb8b3f7453172c863ce2abd974c30f2fe736e84 Mon Sep 17 00:00:00 2001 From: CharlesFeng Date: Wed, 4 Sep 2024 14:57:04 +0800 Subject: [PATCH] fix: err degenerated to a new variable (#35891) https://github.com/milvus-io/milvus/issues/35890 Signed-off-by: fengjun2016 --- internal/datanode/importv2/task_l0_import.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/datanode/importv2/task_l0_import.go b/internal/datanode/importv2/task_l0_import.go index c0e6028f44..71f08a6f60 100644 --- a/internal/datanode/importv2/task_l0_import.go +++ b/internal/datanode/importv2/task_l0_import.go @@ -143,11 +143,13 @@ func (t *L0ImportTask) Execute() []*conc.Future[any] { fmt.Sprintf("there should be one prefix for l0 import, but got %v", t.req.GetFiles())) return } - pkField, err := typeutil.GetPrimaryFieldSchema(t.GetSchema()) + var pkField *schemapb.FieldSchema + pkField, err = typeutil.GetPrimaryFieldSchema(t.GetSchema()) if err != nil { return } - reader, err := binlog.NewL0Reader(t.ctx, t.cm, pkField, t.req.GetFiles()[0], bufferSize) + var reader binlog.L0Reader + reader, err = binlog.NewL0Reader(t.ctx, t.cm, pkField, t.req.GetFiles()[0], bufferSize) if err != nil { return }