flink-on-k8s-operator
flink-on-k8s-operator copied to clipboard
auto start from savepoint when upgrade the image?
I custom build flink image with jars. at now for savepoints
autoSavepointSeconds: 300
restartPolicy: FromSavepointOnFailure
This is only for OnFailture
. Can we auto restore from latest savepoint when I re apply yaml or upgrade the image for the job.(Which is not failture but normal code update)
It is already supported feature. note: https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/docs/user_guide.md#update-flink-clusters-and-jobs
But I think the update policy need to be elaborated more. PR #420 is created for that.
Thanks.
I already pull some fixs branch (which not merged to master) to make 1.19 eks work. This PR #420 conflict so much. It is possible to make priority for these waiting pull request. We have release version. The master may be radical than now time
I also have a suggestion for this project to be more general for k8s not aim at GCP.