diff --git a/internal/util/rocksmq/server/rocksmq/global_rmq.go b/internal/util/rocksmq/server/rocksmq/global_rmq.go index 46761e75ab35a0784db8bfccfdb65267c6140ed8..79fdd4d4c970dae464f3167438deb2a81ba39445 100644 --- a/internal/util/rocksmq/server/rocksmq/global_rmq.go +++ b/internal/util/rocksmq/server/rocksmq/global_rmq.go @@ -12,7 +12,6 @@ package rocksmq import ( - "os" "sync" "github.com/milvus-io/milvus/internal/allocator" @@ -33,9 +32,6 @@ func InitRocksMQ(rocksdbName string) error { var err error once.Do(func() { kvname := rocksdbName + "_kv" - if _, err := os.Stat(kvname); !os.IsNotExist(err) { - _ = os.RemoveAll(kvname) - } rocksdbKV, err := rocksdbkv.NewRocksdbKV(kvname) if err != nil { panic(err) @@ -43,9 +39,6 @@ func InitRocksMQ(rocksdbName string) error { idAllocator := allocator.NewGlobalIDAllocator("rmq_id", rocksdbKV) _ = idAllocator.Initialize() - if _, err := os.Stat(rocksdbName); !os.IsNotExist(err) { - _ = os.RemoveAll(rocksdbName) - } Rmq, err = NewRocksMQ(rocksdbName, idAllocator) if err != nil { panic(err) @@ -57,9 +50,5 @@ func InitRocksMQ(rocksdbName string) error { func CloseRocksMQ() { if Rmq != nil && Rmq.store != nil { Rmq.store.Close() - rocksdbName := Rmq.store.Name() - _ = os.RemoveAll(rocksdbName) - kvname := rocksdbName + "_kv" - os.RemoveAll(kvname) } }