From 3c90dddebf31be6a06b9f9c14493d416ab75debf Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Thu, 20 Nov 2025 17:12:38 +0800 Subject: [PATCH] fix: streamingnode should exit when initializing failure (#45731) issue: #45721 Signed-off-by: chyezh --- internal/streamingnode/server/server.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/streamingnode/server/server.go b/internal/streamingnode/server/server.go index 971627da70..0a013032c2 100644 --- a/internal/streamingnode/server/server.go +++ b/internal/streamingnode/server/server.go @@ -43,7 +43,9 @@ func (s *Server) init() { s.initService() log.Info("init query segcore...") - initcore.InitQueryNode(context.TODO()) + if err := initcore.InitQueryNode(context.TODO()); err != nil { + panic(fmt.Sprintf("init query node segcore failed, %+v", err)) + } log.Info("streamingnode server initialized") }