You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2023/03/22 00:22:00 UTC
[ratis] branch master updated: RATIS-1662. Intermittent failure in testEnforceLeader (#860)
This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git
The following commit(s) were added to refs/heads/master by this push:
new 669223453 RATIS-1662. Intermittent failure in testEnforceLeader (#860)
669223453 is described below
commit 6692234535bc45ff60c8e54c7164b0d18093e5c6
Author: Kaijie Chen <ck...@apache.org>
AuthorDate: Wed Mar 22 08:21:55 2023 +0800
RATIS-1662. Intermittent failure in testEnforceLeader (#860)
---
.../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 205de19a2..dc22e2743 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
@@ -317,6 +317,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);
}