Skip to content

Commit d63240b

Browse files
committed
Fixed - INFO REPLICATION timeout logging
1 parent 7b914c6 commit d63240b

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

redisson/src/main/java/org/redisson/connection/ClusterConnectionManager.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -954,7 +954,15 @@ private CompletableFuture<Collection<ClusterPartition>> parsePartitions(List<Clu
954954
RedisURI finalAddress = address;
955955
return connectionFuture.thenCompose(con -> {
956956
RFuture<Map<String, String>> future = con.async(StringCodec.INSTANCE, RedisCommands.INFO_REPLICATION);
957-
return future.thenCompose(info -> {
957+
return future.handle((info, ex) -> {
958+
if (ex != null) {
959+
if (ex instanceof RedisTimeoutException) {
960+
return null;
961+
}
962+
963+
throw new CompletionException(ex);
964+
}
965+
958966
String masterLinkStatus = info.getOrDefault("master_link_status", "");
959967
if ("down".equals(masterLinkStatus)) {
960968
masterPartition.addFailedSlaveAddress(finalAddress);

0 commit comments

Comments
 (0)