[Fix] fix writing fail in ratisConsensus due to retry policy conditio…

…n mismatch apache#13810
Caideyipi · Oct 17, 2024 · 85e0e15 · 85e0e15
1 parent e854bd7
commit 85e0e15
Showing 1 changed file with 4 additions and 4 deletions.
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
@@ -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(