From 03f63b7ec1e2b43e03c69cf232fc9716234d5261 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Sat, 20 Nov 2021 08:23:13 +0800 Subject: [PATCH] Start querycoord after root/datacoord healthy (#12145) Signed-off-by: xige-16 --- internal/distributed/querycoord/service.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/distributed/querycoord/service.go b/internal/distributed/querycoord/service.go index efc4614e87..cd1a023f95 100644 --- a/internal/distributed/querycoord/service.go +++ b/internal/distributed/querycoord/service.go @@ -139,7 +139,7 @@ func (s *Server) init() error { } // wait for master init or healthy log.Debug("QueryCoord try to wait for RootCoord ready") - err = funcutil.WaitForComponentInitOrHealthy(s.loopCtx, s.rootCoord, "RootCoord", 1000000, time.Millisecond*200) + err = funcutil.WaitForComponentHealthy(s.loopCtx, s.rootCoord, "RootCoord", 1000000, time.Millisecond*200) if err != nil { log.Debug("QueryCoord wait for RootCoord ready failed", zap.Error(err)) panic(err) @@ -168,7 +168,7 @@ func (s *Server) init() error { panic(err) } log.Debug("QueryCoord try to wait for DataCoord ready") - err = funcutil.WaitForComponentInitOrHealthy(s.loopCtx, s.dataCoord, "DataCoord", 1000000, time.Millisecond*200) + err = funcutil.WaitForComponentHealthy(s.loopCtx, s.dataCoord, "DataCoord", 1000000, time.Millisecond*200) if err != nil { log.Debug("QueryCoord wait for DataCoord ready failed", zap.Error(err)) panic(err)