diff --git a/src/main/java/org/redisson/RedissonCacheEvictScheduler.java b/src/main/java/org/redisson/RedissonCacheEvictScheduler.java index 7f8e15413..d12c34f87 100644 --- a/src/main/java/org/redisson/RedissonCacheEvictScheduler.java +++ b/src/main/java/org/redisson/RedissonCacheEvictScheduler.java @@ -70,6 +70,11 @@ public class RedissonCacheEvictScheduler { future.addListener(new FutureListener() { @Override public void operationComplete(Future future) throws Exception { + if (!future.isSuccess()) { + schedule(); + return; + } + Integer size = future.getNow(); if (sizeHistory.size() == 2) {