mirror of
https://gitee.com/milvus-io/milvus.git
synced 2024-12-04 04:49:08 +08:00
Remove redundant variable load (#9452)
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
This commit is contained in:
parent
4e44e885fc
commit
3dac2611b6
@ -291,9 +291,6 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg {
|
||||
log.Debug(".. Buffer not empty, flushing ..")
|
||||
finishCh := make(chan segmentFlushUnit, 1)
|
||||
|
||||
// Since buffer is not empty, so there must be data for key currentSegID
|
||||
bd, _ := ibNode.insertBuffer.Load(currentSegID)
|
||||
|
||||
ibNode.flushMap.Store(currentSegID, bd.(*BufferData).buffer)
|
||||
clearFn := func() {
|
||||
finishCh <- segmentFlushUnit{field2Path: nil}
|
||||
|
Loading…
Reference in New Issue
Block a user