diff --git a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java index e57019b6d..1efc10850 100644 --- a/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java +++ b/redisson/src/main/java/org/redisson/RedissonLocalCachedMap.java @@ -120,6 +120,7 @@ public class RedissonLocalCachedMap extends RedissonMap implements R if (syncStrategy == SyncStrategy.UPDATE) { ByteBuf mapValue = encodeMapValue(value); msg = new LocalCachedMapUpdate(instanceId, mapKey, mapValue); + mapValue.release(); } else { msg = new LocalCachedMapInvalidate(instanceId, cacheKey.getKeyHash()); }