diff --git a/internal/rootcoord/alter_database_task.go b/internal/rootcoord/alter_database_task.go index 9be65b104f..61b481c6ac 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