diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go
index 49944fc5e1..7dee63febb 100644
--- a/internal/datacoord/server.go
+++ b/internal/datacoord/server.go
@@ -211,7 +211,7 @@ func (s *Server) initServiceDiscovery() error {
 		return err
 	}
 
-	s.eventCh = s.session.WatchServices(typeutil.DataNodeRole, rev)
+	s.eventCh = s.session.WatchServices(typeutil.DataNodeRole, rev+1)
 	return nil
 }