fix endless loop caused by ErrCompacted

zeromicro · Dec 17, 2023 · 761c36b · 761c36b
1 parent 8f62a58
commit 761c36b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/discov/internal/registry.go b/core/discov/internal/registry.go
@@ -294,9 +294,9 @@ func (c *cluster) watch(cli EtcdClient, key string, rev int64) {
 		if err == nil {
 			return
 		}
-		if errors.Is(err, v3rpc.ErrCompacted) {
+		if rev != 0 && errors.Is(err, v3rpc.ErrCompacted) {
 			logx.Errorf("etcd watch stream has been compacted, try to reload, rev %v", rev)
-			c.reload(cli)
+			rev = c.load(cli, key)
 		}
 	}
 }