Chris Riccomini created SAMZA-193:
-------------------------------------
Summary: 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
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)
