This is an automated email from the ASF dual-hosted git repository. szetszwo pushed a commit to branch release-3.1.3_review in repository https://gitbox.apache.org/repos/asf/ratis.git
commit 4f82123a38531fc22ff58c72f91c49275a9f506e Author: 荻升 <[email protected]> AuthorDate: Sun Dec 22 21:27:48 2024 +0800 RATIS-212. Fix typo in RaftAsyncTests (#1197) Co-authored-by: Janos Gub <[email protected]> --- ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java b/ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java index 925b8bbad..3a760a806 100644 --- a/ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java +++ b/ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java @@ -281,18 +281,18 @@ public abstract class RaftAsyncTests<CLUSTER extends MiniRaftCluster> extends Ba } void runTestStaleReadAsync(CLUSTER cluster) throws Exception { - final int numMesssages = 10; + final int numMessages = 10; try (RaftClient client = cluster.createClient()) { RaftTestUtil.waitForLeader(cluster); // submit some messages final List<CompletableFuture<RaftClientReply>> futures = new ArrayList<>(); - for (int i = 0; i < numMesssages; i++) { + for (int i = 0; i < numMessages; i++) { final String s = "" + i; LOG.info("sendAsync " + s); futures.add(client.async().send(new SimpleMessage(s))); } - Assert.assertEquals(numMesssages, futures.size()); + Assert.assertEquals(numMessages, futures.size()); final List<RaftClientReply> replies = new ArrayList<>(); for (CompletableFuture<RaftClientReply> f : futures) { final RaftClientReply r = f.join(); @@ -322,7 +322,7 @@ public abstract class RaftAsyncTests<CLUSTER extends MiniRaftCluster> extends Ba StateMachineException.class, IndexOutOfBoundsException.class); // test sendStaleReadAsync - for (int i = 0; i < numMesssages; i++) { + for (int i = 0; i < numMessages; i++) { final RaftClientReply reply = replies.get(i); final String query = "" + i; LOG.info("query=" + query + ", reply=" + reply);
