-
Notifications
You must be signed in to change notification settings - Fork 403
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
[FLINK-32012] Provide rollback feature on savepoint upgrade mode if HA missing and JM never started #622
Conversation
0976e4b
to
66dce2c
Compare
...rator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java
Outdated
Show resolved
Hide resolved
6c056df
to
070472a
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this turned out to be a pretty nice and simple implementation piggybacking on the existing logic. However we should add some new test cases that cover the scenarios we wished to enable here in the first place.
...src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java
Outdated
Show resolved
Hide resolved
...rator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java
Outdated
Show resolved
Hide resolved
cdf9850
to
434cc36
Compare
Can you please rebase it to the latest changes on master so we can run the e2es? |
c22f02d
to
5279182
Compare
...n/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java
Outdated
Show resolved
Hide resolved
.../apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java
Outdated
Show resolved
Hide resolved
…A missing and JM never started If JM has never started and we rely on savepoint upgrade mode the operator can safely rollabck relying on the provided savepoint Also benefit from this change to unify rollback and upgrade code path
af92e3a
to
6a8c179
Compare
There was an issue with new set of commits due to |
Thank you @ashangit for this great contribution :) good stuff |
What is the purpose of the change
This pull request will provide rollback feature If the JobManagers have never started and we rely on savepoint upgrade mode. The operator will safely rollback relying on the provided savepoint
Also benefit from this change to unify rollback and upgrade code path
Brief change log
Verifying this change
(Please pick either of the following options)
This change is already covered by existing tests, such as (please describe tests).
This change added tests and can be verified as follows:
Does this pull request potentially affect one of the following parts:
CustomResourceDescriptors
: yes but in status only adding lastRollbackSpecDocumentation