milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add data sync service error check (#9498) 

Signed-off-by: godchen <qingxiang.chen@zilliz.com>
pull/9562/head
godchen 2021-10-09 15:38:57 +08:00 committed by GitHub
parent 014467fc5a
commit 376be1b532
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/datanode/data_sync_service.go
View File

@ -213,8 +213,11 @@ func (dsService *dataSyncService) initNodes(vchanInfo *datapb.VchannelInfo) erro
zap.Int64("NumOfRows", us.GetNumOfRows()),
)
dsService.replica.addNormalSegment(us.GetID(), us.CollectionID, us.PartitionID, us.GetInsertChannel(),
err = dsService.replica.addNormalSegment(us.GetID(), us.CollectionID, us.PartitionID, us.GetInsertChannel(),
us.GetNumOfRows(), &segmentCheckPoint{us.GetNumOfRows(), *us.GetDmlPosition()})
if err != nil {
return err
}
}
for _, fs := range vchanInfo.GetFlushedSegments() {