admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-06 17:18:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: add init fs check for querynode and streaming node (#44360)

Browse Source 
related: #44354

Signed-off-by: shaoting-huang <shaoting.huang@zilliz.com>
This commit is contained in:
sthuang 2025-09-13 10:31:58 +08:00 committed by GitHub
parent abe22b95c7
commit 9140201b8f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/querynodev2/server.go
View File

@ -336,9 +336,11 @@ func (node *QueryNode) InitSegcore() error {
return err
}
err = initcore.InitStorageV2FileSystem(paramtable.Get())
if err != nil {
return err
if paramtable.Get().CommonCfg.EnableStorageV2.GetAsBool() {
err = initcore.InitStorageV2FileSystem(paramtable.Get())
if err != nil {
return err
}
}
err = initcore.InitMmapManager(paramtable.Get(), node.GetNodeID())

6
internal/streamingnode/server/server.go
View File

@ -46,8 +46,10 @@ func (s *Server) init() {
log.Info("streamingnode server initialized")
// init storage v2 file system.
if err := initcore.InitStorageV2FileSystem(paramtable.Get()); err != nil {
panic(fmt.Sprintf("unrecoverable error happens at init storage v2 file system, %+v", err))
if paramtable.Get().CommonCfg.EnableStorageV2.GetAsBool() {
if err := initcore.InitStorageV2FileSystem(paramtable.Get()); err != nil {
panic(fmt.Sprintf("unrecoverable error happens at init storage v2 file system, %+v", err))
}
}
// init paramtable change callback for core related config