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

No buffer also means flushed (#8686) 

Resolves: #8684

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/8693/head
XuanYang-cn 2021-09-28 11:18:03 +08:00 committed by GitHub
parent 0b99da9301
commit b150f57927
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/datanode/flow_graph_insert_buffer_node.go
View File

@ -271,11 +271,8 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg {
)
bd, ok := ibNode.insertBuffer.Load(currentSegID)
if !ok {
break
}
if bd.(*BufferData).size <= 0 { // Buffer empty
if !ok || bd.(*BufferData).size <= 0 { // Buffer empty
log.Debug(".. Buffer empty ...")
ibNode.dsSaveBinlog(&segmentFlushUnit{
collID: fmsg.collectionID,