Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Allow Flink to ignore savepoint on restore if the states of the old and new jobs are incompatible #589

Open
JuliaBogdan opened this issue Jan 5, 2023 · 0 comments

Comments

@JuliaBogdan
Copy link

We have a streaming job that runs with JobSpec.takeSavepointOnUpdate: true property. When updating the job and restoring it from savepoint, we need to have a way to gracefully handle the failure of the restore process if the new job state and the previous job state are incompatible.

We would like the operator to:

  1. Make an attempt to restore from savepoint
  2. If it does not succeed, ignore savepoint and start the job with the default state.

Since there are cases for which this approach is not acceptable, it would be good to have an option to configure the desired behaviour.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant