diff --git a/src/main/java/org/redisson/RedissonSet.java b/src/main/java/org/redisson/RedissonSet.java
index 68c29d920..a920ba04c 100644
--- a/src/main/java/org/redisson/RedissonSet.java
+++ b/src/main/java/org/redisson/RedissonSet.java
@@ -75,10 +75,10 @@ public class RedissonSet<V> implements Set<V> {
 
     @Override
     public boolean retainAll(Collection<?> c) {
-        int changed = 0;
         RedisConnection<Object, Object> conn = redisson.connect();
         try {
             while (true) {
+                int changed = 0;
                 conn.watch(name);
                 Iterator<V> iterator = (Iterator<V>) conn.smembers(name).iterator();
                 conn.multi();