diff --git a/cmd/tools/migration/backend/etcd220.go b/cmd/tools/migration/backend/etcd220.go index 8ad186e488..46928fee65 100644 --- a/cmd/tools/migration/backend/etcd220.go +++ b/cmd/tools/migration/backend/etcd220.go @@ -3,6 +3,8 @@ package backend import ( "fmt" + "github.com/milvus-io/milvus/internal/metastore/kv/querycoord" + "github.com/milvus-io/milvus/cmd/tools/migration/configs" "github.com/milvus-io/milvus/internal/util" @@ -128,8 +130,13 @@ func (b etcd220) Clean() error { rootcoord.FieldMetaPrefix, rootcoord.AliasMetaPrefix, + rootcoord.SnapshotPrefix, + util.FieldIndexPrefix, util.SegmentIndexPrefix, + + querycoord.CollectionLoadInfoPrefix, + querycoord.PartitionLoadInfoPrefix, } for _, prefix := range prefixes { if err := b.CleanWithPrefix(prefix); err != nil {