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

Fix flow_graph_insert_buffer_node.go code style (#17216) 

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
pull/17205/head
Jiquan Long 2022-05-25 17:03:59 +08:00 committed by GitHub
parent e06d6d7cc6
commit c12ee2f5cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datanode/flow_graph_insert_buffer_node.go
View File

@ -351,9 +351,7 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg {
case resendTTMsg := <-ibNode.resendTTChan:
log.Info("resend TT msg received in insertBufferNode",
zap.Int64s("segment IDs", resendTTMsg.segmentIDs))
if err := ibNode.writeHardTimeTick(fgMsg.timeRange.timestampMax, resendTTMsg.segmentIDs); err != nil {
log.Error("send hard time tick into pulsar channel failed", zap.Error(err))
}
ibNode.writeHardTimeTick(fgMsg.timeRange.timestampMax, resendTTMsg.segmentIDs)
default:
}
}