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