diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go
index 1f30d59633..c7a6a1e60c 100644
--- a/internal/datacoord/server.go
+++ b/internal/datacoord/server.go
@@ -553,7 +553,12 @@ func (s *Server) initServiceDiscovery() error {
 		datanodes = append(datanodes, info)
 	}
 
-	s.cluster.Startup(s.ctx, datanodes)
+	log.Info("DataCoord Cluster Manager start up")
+	if err := s.cluster.Startup(s.ctx, datanodes); err != nil {
+		log.Warn("DataCoord Cluster Manager failed to start up", zap.Error(err))
+		return err
+	}
+	log.Info("DataCoord Cluster Manager start up successfully")
 
 	// TODO implement rewatch logic
 	s.dnEventCh = s.session.WatchServicesWithVersionRange(typeutil.DataNodeRole, r, rev+1, nil)