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

Add vChannelName in IBN timetick log (#14527) 

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/14574/head
XuanYang-cn 2021-12-30 10:09:48 +08:00 committed by GitHub
parent b0c2c6ef2a
commit 9d0bc136e0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/datanode/flow_graph_insert_buffer_node.go
View File

@ -64,15 +64,16 @@ type insertBufferNode struct {
flushManager flushManager
timeTickStream msgstream.MsgStream
ttLogger timeTickLogger
ttLogger *timeTickLogger
ttMerger *mergedTimeTickerSender
lastTimestamp Timestamp
}
type timeTickLogger struct {
start atomic.Uint64
counter atomic.Int32
start atomic.Uint64
counter atomic.Int32
vChannelName string
}
func (l *timeTickLogger) LogTs(ts Timestamp) {
@ -91,7 +92,7 @@ func (l *timeTickLogger) LogTs(ts Timestamp) {
func (l *timeTickLogger) printLogs(start, end Timestamp) {
t1, _ := tsoutil.ParseTS(start)
t2, _ := tsoutil.ParseTS(end)
log.Debug("IBN timetick log", zap.Time("from", t1), zap.Time("to", t2), zap.Duration("elapsed", t2.Sub(t1)), zap.Uint64("start", start), zap.Uint64("end", end))
log.Debug("IBN timetick log", zap.Time("from", t1), zap.Time("to", t2), zap.Duration("elapsed", t2.Sub(t1)), zap.Uint64("start", start), zap.Uint64("end", end), zap.String("vChannelName", l.vChannelName))
}
type segmentCheckPoint struct {
@ -772,5 +773,6 @@ func newInsertBufferNode(ctx context.Context, flushCh <-chan flushMsg, fm flushM
idAllocator: config.allocator,
channelName: config.vChannelName,
ttMerger: mt,
ttLogger: &timeTickLogger{vChannelName: config.vChannelName},
}, nil
}