Updated Redisson cluster mode config init.

Netflix · Nov 13, 2019 · 952953e · 952953e
1 parent 90ab659
commit 952953e
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/redis-lock/src/main/java/com/netflix/conductor/locking/redis/RedisLock.java b/redis-lock/src/main/java/com/netflix/conductor/locking/redis/RedisLock.java
@@ -46,7 +46,10 @@ public RedisLock(RedisLockConfiguration configuration) {
                 config.useSingleServer().setAddress(redisServerAddress).setTimeout(connectionTimeout);
                 break;
             case CLUSTER:
-                config.useClusterServers().addNodeAddress(redisServerAddress).setTimeout(connectionTimeout);
+                config.useClusterServers()
+                        .setScanInterval(2000) // cluster state scan interval in milliseconds
+                        .addNodeAddress(redisServerAddress.split(","))
+                        .setTimeout(connectionTimeout);
                 break;
             case SENTINEL:
                 config.useSentinelServers().addSentinelAddress(redisServerAddress).setTimeout(connectionTimeout);
@@ -104,11 +107,6 @@ public void releaseLock(String lockId) {
         }
     }
 
-    /**
-     * Redlock deletes the lock on release.
-     * @param lockId
-     * @return
-     */
     @Override
     public void deleteLock(String lockId) {
         // Noop for Redlock algorithm as releaseLock / unlock deletes it.