Skip to content

Commit 3aaf34d

Browse files
committed
Fix last typo. I swear
1 parent d54d08f commit 3aaf34d

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1823,7 +1823,7 @@ public <V> void shouldHandleWindowKeyQuery(
18231823
final Integer key,
18241824
final Instant timeFrom,
18251825
final Instant timeTo,
1826-
final Function<V, Integer> valueExtactor,
1826+
final Function<V, Integer> valueExtractor,
18271827
final Set<Integer> expectedValues) {
18281828

18291829
final WindowKeyQuery<Integer, V> query = WindowKeyQuery.withKeyAndWindowStartRange(
@@ -1864,7 +1864,7 @@ public <V> void shouldHandleWindowKeyQuery(
18641864

18651865
try (final WindowStoreIterator<V> iterator = queryResult.get(partition).getResult()) {
18661866
while (iterator.hasNext()) {
1867-
actualValues.add(valueExtactor.apply(iterator.next().value));
1867+
actualValues.add(valueExtractor.apply(iterator.next().value));
18681868
}
18691869
}
18701870
assertThat(queryResult.get(partition).getExecutionInfo(), is(empty()));

0 commit comments

Comments
 (0)