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")
 }