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

Add flowgraph insert buffer node error check (#9310) 

Signed-off-by: godchen <qingxiang.chen@zilliz.com>
pull/9353/head
godchen 2021-10-06 21:06:23 +08:00 committed by GitHub
parent f2e716d360
commit 83228c35ad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datanode/flow_graph_insert_buffer_node.go
View File

@ -274,13 +274,17 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg {
if !ok || bd.(*BufferData).size <= 0 { // Buffer empty
log.Debug(".. Buffer empty ...")
ibNode.dsSaveBinlog(&segmentFlushUnit{
err = ibNode.dsSaveBinlog(&segmentFlushUnit{
collID: fmsg.collectionID,
segID: currentSegID,
field2Path: map[UniqueID]string{},
checkPoint: ibNode.replica.listSegmentsCheckPoints(),
flushed: true,
})
if err != nil {
log.Debug("insert buffer node save binlog failed", zap.Error(err))
break
}
ibNode.replica.segmentFlushed(currentSegID)
} else { // Buffer not empty
log.Debug(".. Buffer not empty, flushing ..")