mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-08 01:58:34 +08:00
Remove log string concat in root_coord.go (#12932)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
parent
1195f441b2
commit
c289a19fb8
@ -449,7 +449,7 @@ func (c *Core) setMsgStreams() error {
|
|||||||
}
|
}
|
||||||
timeTickStream, _ := c.msFactory.NewMsgStream(c.ctx)
|
timeTickStream, _ := c.msFactory.NewMsgStream(c.ctx)
|
||||||
timeTickStream.AsProducer([]string{Params.TimeTickChannel})
|
timeTickStream.AsProducer([]string{Params.TimeTickChannel})
|
||||||
log.Debug("rootcoord AsProducer: " + Params.TimeTickChannel)
|
log.Debug("RootCoord register timetick producer success", zap.String("channel name", Params.TimeTickChannel))
|
||||||
|
|
||||||
c.SendTimeTick = func(t typeutil.Timestamp, reason string) error {
|
c.SendTimeTick = func(t typeutil.Timestamp, reason string) error {
|
||||||
msgPack := ms.MsgPack{}
|
msgPack := ms.MsgPack{}
|
||||||
@ -1181,7 +1181,7 @@ func (c *Core) Start() error {
|
|||||||
Params.UpdatedTime = time.Now()
|
Params.UpdatedTime = time.Now()
|
||||||
|
|
||||||
c.UpdateStateCode(internalpb.StateCode_Healthy)
|
c.UpdateStateCode(internalpb.StateCode_Healthy)
|
||||||
log.Debug(typeutil.RootCoordRole+" start successfully ", zap.String("State Code", internalpb.StateCode_name[int32(internalpb.StateCode_Healthy)]))
|
log.Debug("RootCoord start successfully ", zap.String("State Code", internalpb.StateCode_Healthy.String()))
|
||||||
})
|
})
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user