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

Posted to dev@samza.apache.org by ShuQi <sh...@163.com> on 2021/03/03 03:19:14 UTC

Error when using checkpoint-tool.sh


Hi,


    Now I am using Samza 1.11.0 and Kafka 0.11.0.2, Java version is 1.8.
    Everything is fine，but an error occurred when trying to get latest offset information through checkpoint-tool.sh.
    The exception stacks is below, and task.checkpoint.factory is actually defined in configuration file.


    Exception in thread "main" org.apache.samza.SamzaException: Configuration: task.checkpoint.factory is not defined.
at org.apache.samza.checkpoint.CheckpointTool.run(CheckpointTool.scala:176)
at org.apache.samza.checkpoint.CheckpointTool$.main(CheckpointTool.scala:157)
at org.apache.samza.checkpoint.CheckpointTool.main(CheckpointTool.scala)


    Can anyone help, thanks.
| |
ShuQi
|
|
shuyunkun@163.com
|
签名由网易邮箱大师定制