From 2aba154ad3e59f9478103a37b1d779060908aa6c Mon Sep 17 00:00:00 2001 From: SimFG Date: Tue, 8 Nov 2022 20:15:04 +0800 Subject: [PATCH] Make the subName unique for the datanode tt channel (#20331) Signed-off-by: SimFG Signed-off-by: SimFG --- internal/datacoord/server.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go index f796f1bbb8..23ddacd7b9 100644 --- a/internal/datacoord/server.go +++ b/internal/datacoord/server.go @@ -484,11 +484,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, paramtable.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)