[
https://issues.apache.org/jira/browse/SAMZA-2614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuhong Cheng updated SAMZA-2614:
--------------------------------
Summary: Fix NPE in standby container when (was: Fix KafkaCheckpoint start
null error)
> Fix NPE in standby container when
> ---------------------------------
>
> Key: SAMZA-2614
> URL: https://issues.apache.org/jira/browse/SAMZA-2614
> Project: Samza
> Issue Type: Bug
> Reporter: Yuhong Cheng
> Priority: Major
>
> Standby containers don't really checkpoint or consume input so its possible
> that there is no checkpointing going on. So the kafkaCheckpointManager may
> not be registered when after creating kafkaCheckpointManager. Which causing
> SamzaContainer [ERROR] Caught exception/error while initializing container.
> java.lang.NullPointerException: null at
> org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.start(KafkaCheckpointManager.scala:113)
> Need to initialize the kafka clients when creating the manager instead of
> creating the clients when registering the ssp.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
