(ratis) branch master updated: RATIS-212. Fix typo in RaftAsyncTests (#1197)

[adoroszlai]

This is an automated email from the ASF dual-hosted git repository.

adoroszlai 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 92c4f72f1 RATIS-212. Fix typo in RaftAsyncTests (#1197)
92c4f72f1 is described below

commit 92c4f72f1549fde810a612601429ab52d155d1a5
Author: 荻升 <63136897+ongdish...@users.noreply.github.com>
AuthorDate: Sun Dec 22 21:27:48 2024 +0800

    RATIS-212. Fix typo in RaftAsyncTests (#1197)
    
    Co-authored-by: Janos Gub <j...@hortonworks.com>
---
 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);