Skip to content

Commit 5b4e203

Browse files
Minor unit test code comments improvement
1 parent dfc0366 commit 5b4e203

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/test/java/kafka/server/share/DelayedShareFetchTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1461,7 +1461,7 @@ public void testRemoteStorageFetchRequestCompletionOnFutureCompletionSuccessfull
14611461

14621462
SharePartition sp0 = mock(SharePartition.class);
14631463

1464-
// sp0 is acquirable, sp1 is not acquirable.
1464+
// sp0 is acquirable.
14651465
when(sp0.maybeAcquireFetchLock()).thenReturn(true);
14661466
when(sp0.canAcquireRecords()).thenReturn(true);
14671467

@@ -1530,7 +1530,7 @@ public void testRemoteStorageFetchRequestCompletionAlongWithLocalLogRead() {
15301530
SharePartition sp1 = mock(SharePartition.class);
15311531
SharePartition sp2 = mock(SharePartition.class);
15321532

1533-
// Except tp3, all the topic partitions are acquirable.
1533+
// All the topic partitions are acquirable.
15341534
when(sp0.maybeAcquireFetchLock()).thenReturn(true);
15351535
when(sp1.maybeAcquireFetchLock()).thenReturn(true);
15361536
when(sp2.maybeAcquireFetchLock()).thenReturn(true);

0 commit comments

Comments
 (0)