diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java index 1f1e58f811f4..63e4a2588c8d 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java @@ -188,10 +188,10 @@ public RatisConsensus(ConsensusConfig config, IStateMachine.Registry registry) { .setRetryHandler( reply -> !reply.isSuccess() - && (reply.getException() instanceof ResourceUnavailableException) - && (reply.getException() instanceof LeaderNotReadyException) - && (reply.getException() instanceof LeaderSteppingDownException) - && (reply.getException() instanceof StateMachineException)) + && ((reply.getException() instanceof ResourceUnavailableException) + || reply.getException() instanceof LeaderNotReadyException + || reply.getException() instanceof LeaderSteppingDownException + || reply.getException() instanceof StateMachineException)) .setMaxAttempts(this.config.getImpl().getRetryTimesMax()) .setWaitTime( TimeDuration.valueOf(