You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Yuhong Cheng (Jira)" <ji...@apache.org> on 2021/01/05 00:57:00 UTC

[jira] [Updated] (SAMZA-2614) Fix NPE in standby container when

     [ 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)