From 23f92262506be30d022908168fb27cdba92a3afb Mon Sep 17 00:00:00 2001 From: Xianhui Lin <35839735+JsDove@users.noreply.github.com> Date: Tue, 15 Apr 2025 09:44:30 +0800 Subject: [PATCH] fix: Initialize streaming coordinator during mixCoord initialization (#41283) relater-pr: https://github.com/milvus-io/milvus/pull/41006 issue: https://github.com/milvus-io/milvus/issues/41282 Signed-off-by: Xianhui.Lin --- internal/coordinator/mix_coord.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/coordinator/mix_coord.go b/internal/coordinator/mix_coord.go index 7ca1bfad22..804021cce2 100644 --- a/internal/coordinator/mix_coord.go +++ b/internal/coordinator/mix_coord.go @@ -131,6 +131,7 @@ func (s *mixCoordImpl) Init() error { } s.factory.Init(Params) s.initKVCreator() + s.initStreamingCoord() if s.enableActiveStandBy { s.activateFunc = func() error { log.Info("mixCoord switch from standby to active, activating") @@ -162,7 +163,6 @@ func (s *mixCoordImpl) Init() error { func (s *mixCoordImpl) initInternal() error { log := log.Ctx(s.ctx) - s.initStreamingCoord() s.rootcoordServer.SetMixCoord(s) s.datacoordServer.SetMixCoord(s) s.queryCoordServer.SetMixCoord(s)