We have a source/sink mechanism which uses checkpoints for persistence and
can operate in a minor data loss scenario. Is there a method to use
checkpoints (to enable use of those source/sink operators) while disabling
stateful recovery during restarts?

Our setup uses Flink 1.16.1 alongside Flink Kubernetes Operator 1.5.0. We
are also using stateless upgrades with the operator but while the job is
restarting, it's still restoring from the last stable checkpoint. Is there
any option in Flink or Flink Kubernetes Operator which could help us in
this?

Reply via email to