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: set sourceNodes to null for selectKey
Date Thu, 15 Sep 2016 15:42:24 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 068f93511 -> 3262ae29a


HOTFIX: set sourceNodes to null for selectKey

To indicate its source topic is no longer guaranteed to be partitioned on key.

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Matthias J. Sax, Damian Guy, Eno Thereska

Closes #1858 from guozhangwang/KHotfix-set-null-sourceNodes-selectKey


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3262ae29
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3262ae29
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3262ae29

Branch: refs/heads/0.10.0
Commit: 3262ae29ae57966850b8dc064111ba30714b2f08
Parents: 068f935
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Thu Sep 15 08:42:21 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Sep 15 08:42:21 2016 -0700

----------------------------------------------------------------------
 .../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/3262ae29/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 91bcef9..60d2366 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
@@ -132,7 +132,7 @@ public class KStreamImpl<K, V> extends AbstractStream<K> implements
KStream<K, V
                 return new KeyValue(mapper.apply(key, value), value);
             }
         }), this.name);
-        return new KStreamImpl<>(topology, name, sourceNodes);
+        return new KStreamImpl<>(topology, name, null);
     }
 
     @Override


Mime
View raw message