Hi, Kamal As Hang says, some extra info about job failover strategy for reference in [1]
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/task_failure_recovery/ Best, Ron Hang Ruan <ruanhang1...@gmail.com> 于2023年8月23日周三 22:27写道： > Hi, Kamal. > > If we don't enable checkpointing, the job will be started with the startup > mode each time. > For example, the job reads Kafka from the earliest offset and writes to > mysql. If the job failover without checkpointing, the tasks will consume > Kafka from the earliest offset again. > > I think it is best to enable checkpointing to restart job from the > position where the job stopped reading. > > Best, > Hang > > Kamal Mittal via user <user@flink.apache.org> 于2023年8月23日周三 18:46写道： > >> Hello, >> >> >> >> If checkpointing is NOT enabled and re-start strategy is configured then >> flink retries the whole job execution i.e. enabling checkpointing is must >> for re-try or not? >> >> >> >> Rgds, >> >> Kamal >> >
