From 0391b8c7d39ce1ec5433ecd592f2ac89d1f3b0cb Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Fri, 17 Jan 2025 10:37:03 +0800 Subject: [PATCH] fix: update rg failed when alter database (#39356) issue: #36933 pr: #39355 Signed-off-by: chyezh --- internal/rootcoord/alter_database_task.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/rootcoord/alter_database_task.go b/internal/rootcoord/alter_database_task.go index 9be65b104fb38..61b481c6ace90 100644 --- a/internal/rootcoord/alter_database_task.go +++ b/internal/rootcoord/alter_database_task.go @@ -34,6 +34,7 @@ import ( "github.com/milvus-io/milvus/pkg/proto/querypb" "github.com/milvus-io/milvus/pkg/proto/rootcoordpb" "github.com/milvus-io/milvus/pkg/util/merr" + "github.com/milvus-io/milvus/pkg/util/typeutil" ) type alterDatabaseTask struct { @@ -177,7 +178,7 @@ func executeAlterDatabaseTaskSteps(ctx context.Context, zap.Strings("newResourceGroups", newResourceGroups), ) redoTask.AddAsyncStep(NewSimpleStep("", func(ctx context.Context) ([]nestedStep, error) { - colls, err := core.meta.ListCollections(ctx, oldDB.Name, ts, true) + colls, err := core.meta.ListCollections(ctx, oldDB.Name, typeutil.MaxTimestamp, true) if err != nil { log.Ctx(ctx).Warn("failed to trigger update load config for database", zap.Int64("dbID", oldDB.ID), zap.Error(err)) return nil, err