Repository: kafka Updated Branches: refs/heads/trunk 695fdc69d -> 79662cc7c
HOTFIX: Use the correct serde classes Author: Guozhang Wang <[email protected]> Reviewers: Yasuhiro Matsuda Closes #991 from guozhangwang/KSerde Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/79662cc7 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/79662cc7 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/79662cc7 Branch: refs/heads/trunk Commit: 79662cc7cb139c33888148139f44fb4b1ac0fe56 Parents: 695fdc6 Author: Guozhang Wang <[email protected]> Authored: Tue Mar 1 16:27:45 2016 -0800 Committer: Guozhang Wang <[email protected]> Committed: Tue Mar 1 16:27:45 2016 -0800 ---------------------------------------------------------------------- .../org/apache/kafka/streams/kstream/internals/KStreamImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/79662cc7/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java index 9f384ce..cff082c 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java @@ -307,7 +307,7 @@ public class KStreamImpl<K, V> extends AbstractStream<K> implements KStream<K, V StateStoreSupplier thisWindow = Stores.create(windows.name() + "-this") .withKeys(keySerializer, keyDeserializer) - .withValues(otherValueSerializer, otherValueDeserializer) + .withValues(thisValueSerializer, thisValueDeserializer) .persistent() .windowed(windows.maintainMs(), windows.segments, true) .build();
