[
https://issues.apache.org/jira/browse/SAMZA-193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13942607#comment-13942607
]
Yan Fang commented on SAMZA-193:
--------------------------------
all right, I just ran into this exception today...*_*
> 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
>
> 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)
