Skip to content

Commit

Permalink
HOTFIX: compilation error
Browse files Browse the repository at this point in the history
Two merged PRs overlapped in a non-conflicting way, breaking compilation:
 - apache#18722
 - apache#18755
  • Loading branch information
mjsax authored and pdruley committed Feb 12, 2025
1 parent bd68dd1 commit df117ff
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -259,7 +259,7 @@ public <VOut> KStream<K, VOut> mapValues(final ValueMapperWithKey<? super K, ? s
Objects.requireNonNull(named, "named can't be null");

final String name = new NamedInternal(named).orElseGenerateWithPrefix(builder, MAPVALUES_NAME);
final ProcessorParameters<K, V, K, VR> processorParameters =
final ProcessorParameters<K, V, K, VOut> processorParameters =
new ProcessorParameters<>(new KStreamMapValues<>(valueMapperWithKey), name);
final ProcessorGraphNode<K, V> mapValuesProcessorNode =
new ProcessorGraphNode<>(name, processorParameters);
Expand Down Expand Up @@ -290,7 +290,7 @@ public <KOut, VOut> KStream<KOut, VOut> map(final KeyValueMapper<? super K, ? su
Objects.requireNonNull(named, "named can't be null");

final String name = new NamedInternal(named).orElseGenerateWithPrefix(builder, MAP_NAME);
final ProcessorParameters<K, V, KR, VR> processorParameters =
final ProcessorParameters<K, V, KOut, VOut> processorParameters =
new ProcessorParameters<>(new KStreamMap<>(mapper), name);
final ProcessorGraphNode<K, V> mapProcessorNode =
new ProcessorGraphNode<>(name, processorParameters);
Expand Down

0 comments on commit df117ff

Please sign in to comment.