diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go
index 2116478e9a..12d9b8a06e 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
 	}