Skip to content

Commit 651e649

Browse files
committed
Clear client side cache during cluster reconfiguration
1 parent b8c7a54 commit 651e649

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

Diff for: src/main/java/redis/clients/jedis/JedisClusterInfoCache.java

+3
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,9 @@ private void discoverClusterSlots(Connection jedis) {
226226
try {
227227
Arrays.fill(slots, null);
228228
Arrays.fill(slotNodes, null);
229+
if (clientSideCache != null) {
230+
clientSideCache.clear();
231+
}
229232
Set<String> hostAndPortKeys = new HashSet<>();
230233

231234
for (Object slotInfoObj : slotsInfo) {

0 commit comments

Comments
 (0)