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

Make the subName unique for the datanode tt channel (#21616) 

Signed-off-by: SimFG <bang.fu@zilliz.com>
Co-authored-by: SimFG <bang.fu@zilliz.com>
pull/21627/head
jaime 2023-01-10 17:59:39 +08:00 committed by GitHub
parent de318c2e7c
commit c704037991
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/datacoord/server.go
View File

@ -485,11 +485,12 @@ func (s *Server) startDataNodeTtLoop(ctx context.Context) {
log.Error("DataCoord failed to create timetick channel", zap.Error(err))
panic(err)
}
subName := fmt.Sprintf("%s-%d-datanodeTl", Params.CommonCfg.DataCoordSubName, Params.DataCoordCfg.GetNodeID())
ttMsgStream.AsConsumer([]string{Params.CommonCfg.DataCoordTimeTick},
Params.CommonCfg.DataCoordSubName, mqwrapper.SubscriptionPositionLatest)
subName, mqwrapper.SubscriptionPositionLatest)
log.Info("DataCoord creates the timetick channel consumer",
zap.String("timeTickChannel", Params.CommonCfg.DataCoordTimeTick),
zap.String("subscription", Params.CommonCfg.DataCoordSubName))
zap.String("subscription", subName))
ttMsgStream.Start()
go s.handleDataNodeTimetickMsgstream(ctx, ttMsgStream)