Skip to content

Commit d54d08f

Browse files
committed
Last typo fix
1 parent 03e930a commit d54d08f

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ public class RocksDBTimeOrderedKeyValueBuffer<K, V> implements TimeOrderedKeyVal
5959
private final boolean loggingEnabled;
6060
private int partition;
6161
private String changelogTopic;
62-
private InternalProcessorContext<?, ?> iternalContext;
62+
private InternalProcessorContext<?, ?> internalContext;
6363
private boolean minValid;
6464

6565
public static class Builder<K, V> implements StoreBuilder<TimeOrderedKeyValueBuffer<K, V, V>> {
@@ -188,7 +188,7 @@ public String name() {
188188
@Override
189189
public void init(final StateStoreContext stateStoreContext, final StateStore root) {
190190
store.init(stateStoreContext, root);
191-
iternalContext = ProcessorContextUtils.asInternalProcessorContext(stateStoreContext);
191+
internalContext = ProcessorContextUtils.asInternalProcessorContext(stateStoreContext);
192192
partition = stateStoreContext.taskId().partition();
193193
if (loggingEnabled) {
194194
changelogTopic = ProcessorContextUtils.changelogFor(stateStoreContext, name(), Boolean.TRUE);
@@ -231,7 +231,7 @@ public void evictWhile(final Supplier<Boolean> predicate, final Consumer<Evictio
231231

232232
final BufferValue bufferValue = BufferValue.deserialize(ByteBuffer.wrap(keyValue.value));
233233
final K key = keySerde.deserializer().deserialize(topic,
234-
iternalContext.headers(),
234+
internalContext.headers(),
235235
PrefixedWindowKeySchemas.TimeFirstWindowKeySchema.extractStoreKeyBytes(keyValue.key.get()));
236236

237237
if (bufferValue.context().timestamp() < minTimestamp && minValid) {

0 commit comments

Comments
 (0)