kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: Use the correct serde classes
Date Wed, 02 Mar 2016 00:27:49 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 695fdc69d -> 79662cc7c


HOTFIX: Use the correct serde classes

Author: Guozhang Wang <wangguoz@gmail.com>

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 <wangguoz@gmail.com>
Authored: Tue Mar 1 16:27:45 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
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();


Mime
View raw message