mirror of https://github.com/milvus-io/milvus.git
[skip e2e]Improve log (#13704)
Signed-off-by: sunby <bingyi.sun@zilliz.com> Co-authored-by: sunby <bingyi.sun@zilliz.com>pull/13821/head
parent
a1967e6b01
commit
9d44ea034c
|
@ -429,9 +429,9 @@ func (s *Server) startDataNodeTtLoop(ctx context.Context) {
|
||||||
}
|
}
|
||||||
ttMsgStream.AsConsumerWithPosition([]string{Params.TimeTickChannelName},
|
ttMsgStream.AsConsumerWithPosition([]string{Params.TimeTickChannelName},
|
||||||
Params.DataCoordSubscriptionName, mqclient.SubscriptionPositionLatest)
|
Params.DataCoordSubscriptionName, mqclient.SubscriptionPositionLatest)
|
||||||
log.Debug("dataCoord create time tick channel consumer",
|
log.Debug("DataCoord creates the timetick channel consumer",
|
||||||
zap.String("timeTickChannelName", Params.TimeTickChannelName),
|
zap.String("timeTickChannel", Params.TimeTickChannelName),
|
||||||
zap.String("subscriptionName", Params.DataCoordSubscriptionName))
|
zap.String("subscription", Params.DataCoordSubscriptionName))
|
||||||
ttMsgStream.Start()
|
ttMsgStream.Start()
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
|
|
Loading…
Reference in New Issue