From 9140201b8f6612a4bb7159ec9ab33e5796c3f4c9 Mon Sep 17 00:00:00 2001 From: sthuang <167743503+shaoting-huang@users.noreply.github.com> Date: Sat, 13 Sep 2025 10:31:58 +0800 Subject: [PATCH] fix: add init fs check for querynode and streaming node (#44360) related: #44354 Signed-off-by: shaoting-huang --- internal/querynodev2/server.go | 8 +++++--- internal/streamingnode/server/server.go | 6 ++++-- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/internal/querynodev2/server.go b/internal/querynodev2/server.go index 1f0197e8dc..fe8332f55a 100644 --- a/internal/querynodev2/server.go +++ b/internal/querynodev2/server.go @@ -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()) diff --git a/internal/streamingnode/server/server.go b/internal/streamingnode/server/server.go index b596ba1132..fcdfad7029 100644 --- a/internal/streamingnode/server/server.go +++ b/internal/streamingnode/server/server.go @@ -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