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

fix: filter new proxy when initializing proxy session at timeticksync (#42831)

Browse Source 
issue: #40532

Signed-off-by: chyezh <chyezh@outlook.com>
This commit is contained in:
Zhen Ye 2025-06-19 16:44:40 +08:00 committed by GitHub
parent 2fd8f910b0
commit fadc053d7a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/rootcoord/timeticksync.go
View File

@ -261,7 +261,15 @@ func (t *timetickSync) initSessions(sess []*sessionutil.Session) {
t.sess2ChanTsMap = make(map[typeutil.UniqueID]*chanTsMsg) t.sess2ChanTsMap = make(map[typeutil.UniqueID]*chanTsMsg)
// Init DDL source // Init DDL source
t.sess2ChanTsMap[ddlSourceID] = nil t.sess2ChanTsMap[ddlSourceID] = nil
rangeChecker := semver.MustParseRange(">=2.6.0-dev")
for _, s := range sess { 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 t.sess2ChanTsMap[s.ServerID] = nil
log.Info("Init proxy sessions for timeticksync", zap.Int64("serverID", s.ServerID)) log.Info("Init proxy sessions for timeticksync", zap.Int64("serverID", s.ServerID))
} }