From 282d2624e0d8856065765b8086363ef3c469bb2a Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 22 Jun 2021 16:20:10 +0800 Subject: [PATCH] Not remove rocksdb folder when close and init (#5974) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/global_rmq.go | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/internal/util/rocksmq/server/rocksmq/global_rmq.go b/internal/util/rocksmq/server/rocksmq/global_rmq.go index 46761e75a..79fdd4d4c 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) } } -- GitLab