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

actually commit the fix

This commit is contained in:
Damian Guy 2016-04-27 08:12:53 +01:00
parent 07ce589429
commit 49d48fb522
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
View File

@ -298,7 +298,7 @@ public class KStreamImpl<K, V> extends AbstractStream<K> implements KStream<K, V
String name = topology.newName(SINK_NAME); String name = topology.newName(SINK_NAME);
Serializer<K> keySerializer = keySerde == null ? null : keySerde.serializer(); Serializer<K> keySerializer = keySerde == null ? null : keySerde.serializer();
Serializer<V> valSerializer = keySerde == null ? null : valSerde.serializer(); Serializer<V> valSerializer = valSerde == null ? null : valSerde.serializer();
if (partitioner == null && keySerializer != null && keySerializer instanceof WindowedSerializer) { if (partitioner == null && keySerializer != null && keySerializer instanceof WindowedSerializer) {
WindowedSerializer<Object> windowedSerializer = (WindowedSerializer<Object>) keySerializer; WindowedSerializer<Object> windowedSerializer = (WindowedSerializer<Object>) keySerializer;