From 11b45684dbeba482e7f38c8fc50229fc2ad18585 Mon Sep 17 00:00:00 2001 From: Ivan Andika Date: Mon, 27 May 2024 14:42:38 +0800 Subject: [PATCH] Update comment and cleanup --- .../ratis/protocol/exceptions/NotReplicatedException.java | 2 +- .../src/test/java/org/apache/ratis/WatchRequestTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotReplicatedException.java b/ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotReplicatedException.java index f4fa305e69..37ff816245 100644 --- a/ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotReplicatedException.java +++ b/ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotReplicatedException.java @@ -26,7 +26,7 @@ public class NotReplicatedException extends RaftException { private final long callId; private final ReplicationLevel requiredReplication; private final long logIndex; - /** This is only populated on client-side based from the commitInfos in RaftClientReply */ + /** This is only populated on client-side since RaftClientReply already has commitInfos */ private Collection commitInfos; public NotReplicatedException(long callId, ReplicationLevel requiredReplication, long logIndex) { diff --git a/ratis-server/src/test/java/org/apache/ratis/WatchRequestTests.java b/ratis-server/src/test/java/org/apache/ratis/WatchRequestTests.java index b1d4708a88..b842ee9db5 100644 --- a/ratis-server/src/test/java/org/apache/ratis/WatchRequestTests.java +++ b/ratis-server/src/test/java/org/apache/ratis/WatchRequestTests.java @@ -559,6 +559,6 @@ static void assertNotReplicatedException(long logIndex, ReplicationLevel replica Assert.assertNotNull(nre); Assert.assertEquals(logIndex, nre.getLogIndex()); Assert.assertEquals(replication, nre.getRequiredReplication()); - Assert.assertNotNull((nre.getCommitInfos())); + Assert.assertNotNull(nre.getCommitInfos()); } }