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

Question: is savepointing required? #57

Open
hadronzoo opened this issue Jul 30, 2019 · 3 comments
Open

Question: is savepointing required? #57

hadronzoo opened this issue Jul 30, 2019 · 3 comments

Comments

@hadronzoo
Copy link

hadronzoo commented Jul 30, 2019

Thank you for developing and open-sourcing this operator! Maintaining Flink jobs with state on Kubernetes without it has been error prone. Quick question: I'd also like to use this operator for Flink jobs without a persistent state requirement. Is it possible to deploy a new version of a job without restoring from a savepoint when state doesn't matter?

@anandswaminathan
Copy link
Contributor

Hi,

Today, the operator only supports updates to an application by taking a savepoint. We will need to make some changes to the state machine in the operator to support updates without savepoint - something like SavepointInfo - Disabled.

Until we implement that, the only alternate option is to delete the application resource (with deleteMode set to None) and create a new one.

@JonnyIncognito
Copy link
Contributor

Adding my +1 here. We have a number of medium-sized (6M+ records/sec) jobs that are stateless due to idempotency that we'd like to migrate over to FlinkK8sOperator. Cross-linking this issue from an internal backlog as we may help implement it ourselves out of need.

@davidbirdsong
Copy link

Does #184 solve this issue?

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

4 participants