diff --git a/jcommon/redis/src/main/java/com/xiaomi/data/push/redis/ext/PipelineClusterCommand.java b/jcommon/redis/src/main/java/com/xiaomi/data/push/redis/ext/PipelineClusterCommand.java index 6af38c322..9d4b00354 100644 --- a/jcommon/redis/src/main/java/com/xiaomi/data/push/redis/ext/PipelineClusterCommand.java +++ b/jcommon/redis/src/main/java/com/xiaomi/data/push/redis/ext/PipelineClusterCommand.java @@ -130,6 +130,7 @@ private Map> getPoolKeyMap(List keys) { Map> poolKeysMap = new LinkedHashMap>(); try { Field field = JedisClusterConnectionHandler.class.getDeclaredField("cache"); + field.setAccessible(true); for (String key : keys) { JedisPool jedisPool; int slot = JedisClusterCRC16.getSlot(key);