milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: update rg failed when alter database (#39356) 

issue: #36933
pr: #39355

Signed-off-by: chyezh <chyezh@outlook.com>
pull/39380/head
Zhen Ye 2025-01-17 10:37:03 +08:00 committed by GitHub
parent b69994272f
commit 0391b8c7d3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/rootcoord/alter_database_task.go
View File

@ -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