[SAMZA-193] Closing KafkaCheckpointManager causes NPE

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.6.0
• Fix Version/s: 0.7.0
• Component/s: kafka
• Labels: newbie
• Assignee: Unassigned
• Reporter: Chris Riccomini
• Created: 18/Mar/14 22:32
• Updated: 21/Mar/14 04:00
• Resolved: 21/Mar/14 03:59

Description

If you close a disconnected KafkaCheckpointManager, you get an NPE. This is because the Kafka producer is null when it's not connected.

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)

We just need to add an if statement here.