admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: Initialize streaming coordinator during mixCoord initialization (#41283)

Browse Source 
relater-pr: https://github.com/milvus-io/milvus/pull/41006
issue: https://github.com/milvus-io/milvus/issues/41282

Signed-off-by: Xianhui.Lin <xianhui.lin@zilliz.com>
This commit is contained in:
Xianhui Lin 2025-04-15 09:44:30 +08:00 committed by GitHub
parent 59b14d38f5
commit 23f9226250
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/coordinator/mix_coord.go
View File

@ -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)