diff --git a/internal/rootcoord/root_coord.go b/internal/rootcoord/root_coord.go index 012d26b33806cc71a55cdee53af61753e8cf48d7..6105c81f0112c981491071064a4a220bbb3cab6e 100644 --- a/internal/rootcoord/root_coord.go +++ b/internal/rootcoord/root_coord.go @@ -1088,19 +1088,19 @@ func (c *Core) Start() error { c.startOnce.Do(func() { if err := c.proxyManager.WatchProxy(); err != nil { - log.Debug("RootCoord Start WatchProxy failed", zap.Error(err)) - return + log.Fatal("RootCoord Start WatchProxy failed", zap.Error(err)) + // you can not just stuck here, + panic(err) } if err := c.reSendDdMsg(c.ctx, false); err != nil { - log.Debug("RootCoord Start reSendDdMsg failed", zap.Error(err)) - return + log.Fatal("RootCoord Start reSendDdMsg failed", zap.Error(err)) + panic(err) } c.wg.Add(4) go c.startTimeTickLoop() go c.tsLoop() go c.chanTimeTick.StartWatch(&c.wg) go c.checkFlushedSegmentsLoop() - go c.session.LivenessCheck(c.ctx, func() { log.Error("Root Coord disconnected from etcd, process will exit", zap.Int64("Server Id", c.session.ServerID)) }) @@ -1108,10 +1108,9 @@ func (c *Core) Start() error { Params.UpdatedTime = time.Now() c.stateCode.Store(internalpb.StateCode_Healthy) + log.Debug(typeutil.RootCoordRole+" start successfully ", zap.String("State Code", internalpb.StateCode_name[int32(internalpb.StateCode_Healthy)])) }) - log.Debug(typeutil.RootCoordRole, zap.String("State Code", internalpb.StateCode_name[int32(internalpb.StateCode_Healthy)])) - return nil }