[jira] [Created] (SAMZA-193) Closing KafkaCheckpointManager causes NPE

["Chris Riccomini (JIRA)" <ji...@apache.org>]

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)