test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 10:59:32 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

fix: err degenerated to a new variable (#35891)

Browse Source 
https://github.com/milvus-io/milvus/issues/35890

Signed-off-by: fengjun2016 <jornfeng@gmail.com>
This commit is contained in:
CharlesFeng 2024-09-04 14:57:04 +08:00 committed by GitHub
parent 24fb10114b
commit 6eb8b3f745
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datanode/importv2/task_l0_import.go
View File

@ -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())) fmt.Sprintf("there should be one prefix for l0 import, but got %v", t.req.GetFiles()))
return return
} }
pkField, err := typeutil.GetPrimaryFieldSchema(t.GetSchema()) var pkField *schemapb.FieldSchema
pkField, err = typeutil.GetPrimaryFieldSchema(t.GetSchema())
if err != nil { if err != nil {
return 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 { if err != nil {
return return
} }