From 847b8c8fdc0133f09e51a6b141ef7a70caa589ab Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Tue, 1 Apr 2025 20:04:20 +0800 Subject: [PATCH] fix: node version checker should use -dev before releasing (#41039) issue: #40532 Signed-off-by: chyezh --- internal/streamingcoord/server/balancer/balancer_impl.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/streamingcoord/server/balancer/balancer_impl.go b/internal/streamingcoord/server/balancer/balancer_impl.go index 6d20c8a1ca..7ed244a68d 100644 --- a/internal/streamingcoord/server/balancer/balancer_impl.go +++ b/internal/streamingcoord/server/balancer/balancer_impl.go @@ -181,7 +181,7 @@ func (b *balancerImpl) blockUntilAllNodeIsGreaterThan260(ctx context.Context) er logger := b.logger.With(zap.String("role", role)) logger.Info("start to wait that the nodes is greater than 2.6.0") // Check if there's any proxy or data node with version < 2.6.0. - proxyResolver := resolver.NewSessionBuilder(resource.Resource().ETCD(), sessionutil.GetSessionPrefixByRole(role), "<2.6.0") + proxyResolver := resolver.NewSessionBuilder(resource.Resource().ETCD(), sessionutil.GetSessionPrefixByRole(role), "<2.6.0-dev") r := proxyResolver.Resolver() err := r.Watch(ctx, func(vs resolver.VersionedState) error { if len(vs.Sessions()) == 0 {