fix: err degenerated to a new variable

Signed-off-by: fengjun2016 <[email protected]>
milvus-io · Sep 1, 2024 · 154a28f · 154a28f
1 parent 407fc93
commit 154a28f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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 *l0Reader
+		reader, err = binlog.NewL0Reader(t.ctx, t.cm, pkField, t.req.GetFiles()[0], bufferSize)
 		if err != nil {
 			return
 		}