[
https://issues.apache.org/jira/browse/SAMZA-193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated SAMZA-193:
--------------------------------
Attachment: SAMZA-193-v2.patch
Here, you go.
> Closing KafkaCheckpointManager causes NPE
> -----------------------------------------
>
> Key: SAMZA-193
> URL: https://issues.apache.org/jira/browse/SAMZA-193
> Project: Samza
> Issue Type: Bug
> Components: kafka
> Affects Versions: 0.6.0
> Reporter: Chris Riccomini
> Labels: newbie
> Attachments: SAMZA-193-v2.patch
>
>
> If you close a disconnected KafkaCheckpointManager, you get an NPE. This is
> because the Kafka producer is null when it's not connected.
> {noformat}
> Exception in thread "ThreadJob" java.lang.NullPointerException
> at
> org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.stop(KafkaCheckpointManager.scala:215)
> at
> org.apache.samza.container.SamzaContainer.shutdownCheckpoints(SamzaContainer.scala:655)
> at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:510)
> at org.apache.samza.job.local.ThreadJob$$anon$1.run(ThreadJob.scala:42)
> {noformat}
> We just need to add an if statement here.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
