MabelYC opened a new pull request #1454: URL: https://github.com/apache/samza/pull/1454
Symptom: Met error when standby container is starting: SamzaContainer [ERROR] Caught exception/error while initializing container. java.lang.NullPointerException: null at org.apache.samza.checkpoint.kafka.KafkaCheckpointManager.start(KafkaCheckpointManager.scala:113) Cause: Standby containers don't really checkpoint or consume input so its possible that there is no checkpointing going on. So the SSP may not be registered by kafkaCheckpointManager after creating kafkaCheckpointManager, which caused the error. Changes: Creating kafka clients when initializing the kafkaCheckpointManager. Tests: Unit tests and running local test jobs. API Changes: N/A Upgrade Instructions: N/A Usage Instructions: N/A ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
