From 13326092d8f3a0e56650f0e37920535561a2e1e3 Mon Sep 17 00:00:00 2001 From: disheng Date: Sun, 22 Dec 2024 20:21:28 +0800 Subject: [PATCH] RATIS-212. Fix typo in RaftAsyncTests --- .../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 925b8bbadb..3a760a8065 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 void testStaleReadAsync() throws Exception { } 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> 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 replies = new ArrayList<>(); for (CompletableFuture f : futures) { final RaftClientReply r = f.join(); @@ -322,7 +322,7 @@ void runTestStaleReadAsync(CLUSTER cluster) throws Exception { 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);