From be596123d1fcdc7725fb7beee19df29548f4e137 Mon Sep 17 00:00:00 2001 From: sunby Date: Thu, 4 Feb 2021 20:03:19 +0800 Subject: [PATCH] Fix dataservice startup Signed-off-by: sunby --- internal/dataservice/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go index 2116478e9..12d9b8a06 100644 --- a/internal/dataservice/server.go +++ b/internal/dataservice/server.go @@ -141,9 +141,9 @@ func (s *Server) Start() error { if err = s.loadMetaFromMaster(); err != nil { return err } - s.startServerLoop() s.waitDataNodeRegister() s.cluster.WatchInsertChannels(s.insertChannels) + s.startServerLoop() if err = s.initMsgProducer(); err != nil { return err } -- GitLab