You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/04/27 09:19:12 UTC
[jira] [Commented] (KAFKA-3629) KStreamImpl.to(...) throws NPE when
the value SerDe is null
[ https://issues.apache.org/jira/browse/KAFKA-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259690#comment-15259690 ]
ASF GitHub Bot commented on KAFKA-3629:
---------------------------------------
GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/1272
KAFKA-3629 KStreamImpl.to(...) throws NPE when the value SerDe is null
@guozhangwang
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dguy/kafka kstreamimpl-to-npe
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1272.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1272
----
commit 74d396d131dbc1bbbb4e69f3caa1c9031a6d9981
Author: Damian Guy <da...@gmail.com>
Date: 2016-04-27T07:08:51Z
fix npe in KStreamImpl.to(..)
commit 07ce58942936505896675b912710a7606325ebf8
Author: Damian Guy <da...@gmail.com>
Date: 2016-04-27T07:11:15Z
fix npe in KStreamImpl.to(..)
commit 49d48fb522d9cd0292b4e3ea4e684cf5387989b7
Author: Damian Guy <da...@gmail.com>
Date: 2016-04-27T07:12:53Z
actually commit the fix
----
> KStreamImpl.to(...) throws NPE when the value SerDe is null
> -----------------------------------------------------------
>
> Key: KAFKA-3629
> URL: https://issues.apache.org/jira/browse/KAFKA-3629
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.10.0.0
> Reporter: Damian Guy
> Assignee: Guozhang Wang
> Fix For: 0.10.0.0
>
>
> On line 301 of KStreamImpl the null check is against the keySerde rather than the valSerde. This results in an NPE if the valSerde is null
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)