This is an automated email from the ASF dual-hosted git repository. szetszwo pushed a commit to branch branch-2_readIndex in repository https://gitbox.apache.org/repos/asf/ratis.git
commit 14ae143fba1e05482c590dc27d24c45389fd8cc9 Author: Kaijie Chen <[email protected]> AuthorDate: Wed Mar 22 08:21:55 2023 +0800 RATIS-1662. Intermittent failure in testEnforceLeader (#860) (cherry picked from commit 6692234535bc45ff60c8e54c7164b0d18093e5c6) --- .../src/test/java/org/apache/ratis/server/impl/LeaderElectionTests.java | 1 + .../apache/ratis/server/simulation/MiniRaftClusterWithSimulatedRpc.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/ratis-server/src/test/java/org/apache/ratis/server/impl/LeaderElectionTests.java b/ratis-server/src/test/java/org/apache/ratis/server/impl/LeaderElectionTests.java index 76761249b..0ea08da3e 100644 --- a/ratis-server/src/test/java/org/apache/ratis/server/impl/LeaderElectionTests.java +++ b/ratis-server/src/test/java/org/apache/ratis/server/impl/LeaderElectionTests.java @@ -316,6 +316,7 @@ public abstract class LeaderElectionTests<CLUSTER extends MiniRaftCluster> final RaftServer.Division currLeader = cluster.getLeader(); LOG.info("try enforcing leader to " + newLeader + " but " + (currLeader == null ? "no leader for round " + i : "new leader is " + currLeader.getId())); + TimeDuration.ONE_SECOND.sleep(); } LOG.info(cluster.printServers()); diff --git a/ratis-server/src/test/java/org/apache/ratis/server/simulation/MiniRaftClusterWithSimulatedRpc.java b/ratis-server/src/test/java/org/apache/ratis/server/simulation/MiniRaftClusterWithSimulatedRpc.java index 437da929f..d0e7e9f5c 100644 --- a/ratis-server/src/test/java/org/apache/ratis/server/simulation/MiniRaftClusterWithSimulatedRpc.java +++ b/ratis-server/src/test/java/org/apache/ratis/server/simulation/MiniRaftClusterWithSimulatedRpc.java @@ -108,7 +108,7 @@ public class MiniRaftClusterWithSimulatedRpc extends MiniRaftCluster { .map(s -> serverRequestReply.getQueue(s.getId().toString())) .forEach(q -> q.delayTakeRequestTo.set(delayMs)); - final long sleepMs = 3 * getTimeoutMax().toLong(TimeUnit.MILLISECONDS) / 2; + final long sleepMs = 3 * getTimeoutMax().toLong(TimeUnit.MILLISECONDS); Thread.sleep(sleepMs); }
