root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Minor: Fix VoterSetHistoryTest.testAddAt (#16104) 

Reviewers: Luke Chen <showuon@gmail.com>
This commit is contained in:
dengziming 2024-05-30 10:28:07 +08:00 committed by GitHub
parent 3d14690cbf
commit 131ce0ba59
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
raft/src/test/java/org/apache/kafka/raft/internals/VoterSetHistoryTest.java
View File

@ -26,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertThrows;
final public class VoterSetHistoryTest { final public class VoterSetHistoryTest {
@Test @Test
void testStaicVoterSet() { void testStaticVoterSet() {
VoterSet staticVoterSet = new VoterSet(VoterSetTest.voterMap(Arrays.asList(1, 2, 3), true)); VoterSet staticVoterSet = new VoterSet(VoterSetTest.voterMap(Arrays.asList(1, 2, 3), true));
VoterSetHistory votersHistory = new VoterSetHistory(Optional.of(staticVoterSet)); VoterSetHistory votersHistory = new VoterSetHistory(Optional.of(staticVoterSet));
@ -76,6 +76,7 @@ final public class VoterSetHistoryTest {
assertEquals(Optional.empty(), votersHistory.valueAtOrBefore(99)); assertEquals(Optional.empty(), votersHistory.valueAtOrBefore(99));
assertEquals(Optional.of(addedVoterSet), votersHistory.valueAtOrBefore(100)); assertEquals(Optional.of(addedVoterSet), votersHistory.valueAtOrBefore(100));
voterMap.remove(4);
VoterSet removedVoterSet = new VoterSet(new HashMap<>(voterMap)); VoterSet removedVoterSet = new VoterSet(new HashMap<>(voterMap));
votersHistory.addAt(200, removedVoterSet); votersHistory.addAt(200, removedVoterSet);