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
 	}
diff --git a/tests/python/requirements.txt b/tests/python/requirements.txt
index a4136e23e7..fcf08cf5d0 100644
--- a/tests/python/requirements.txt
+++ b/tests/python/requirements.txt
@@ -2,7 +2,7 @@ grpcio==1.26.0
 grpcio-tools==1.26.0
 numpy==1.18.1
 pytest-cov==2.8.1
-pymilvus-distributed==0.0.17
+pymilvus-distributed==0.0.19
 sklearn==0.0
 pytest==4.5.0
 pytest-timeout==1.3.3