From fadc053d7ae5f190c668aec2cdd34ff0ce2489ad Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Thu, 19 Jun 2025 16:44:40 +0800 Subject: [PATCH] fix: filter new proxy when initializing proxy session at timeticksync (#42831) issue: #40532 Signed-off-by: chyezh --- internal/rootcoord/timeticksync.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/internal/rootcoord/timeticksync.go b/internal/rootcoord/timeticksync.go index df5b009b11..c7ad53415d 100644 --- a/internal/rootcoord/timeticksync.go +++ b/internal/rootcoord/timeticksync.go @@ -261,7 +261,15 @@ func (t *timetickSync) initSessions(sess []*sessionutil.Session) { t.sess2ChanTsMap = make(map[typeutil.UniqueID]*chanTsMsg) // Init DDL source t.sess2ChanTsMap[ddlSourceID] = nil + rangeChecker := semver.MustParseRange(">=2.6.0-dev") for _, s := range sess { + if rangeChecker(s.Version) { + log.Info("new proxy with no timetick join, ignored", + zap.String("version", s.Version.String()), + zap.Int64("serverID", s.ServerID), + zap.String("address", s.Address)) + continue + } t.sess2ChanTsMap[s.ServerID] = nil log.Info("Init proxy sessions for timeticksync", zap.Int64("serverID", s.ServerID)) }