You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Daniel Halperin (JIRA)" <ji...@apache.org> on 2017/05/18 19:44:04 UTC

[jira] [Closed] (BEAM-1837) NPE in KafkaIO writer

     [ https://issues.apache.org/jira/browse/BEAM-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Daniel Halperin closed BEAM-1837.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 2.0.0

> NPE in KafkaIO writer
> ---------------------
>
>                 Key: BEAM-1837
>                 URL: https://issues.apache.org/jira/browse/BEAM-1837
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-extensions
>            Reporter: Raghu Angadi
>            Assignee: Raghu Angadi
>             Fix For: 2.0.0
>
>
> {{KafkaIO.writer()...values()}} does not require user to set key coder since the key always null. Validation passes, but it results in an NPE at runtime when the writer is tries to instantiates the producer.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)