admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 01:58:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
Signed-off-by: SimFG <bang.fu@zilliz.com>

Signed-off-by: SimFG <bang.fu@zilliz.com>
This commit is contained in:
SimFG 2022-11-08 20:15:04 +08:00 committed by GitHub
parent 9c6436d72d
commit 2aba154ad3
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

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