How flink job find the savepoint when auto savepointing enabled

GoogleCloudPlatform / flink-on-k8s-operator

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

Apache License 2.0

658 stars 266 forks source link

How flink job find the savepoint when auto savepointing enabled #376

Open yanghui16355 opened 3 years ago

yanghui16355 commented 3 years ago

I want to check how flink job find the savepoint when auto savepointing enabled with operator. Is it track with job ID or job name? Is it possible that it will lose the savepoint when flink job crash or update with new version.

functicons commented 3 years ago

The location of the last savepoint is recorded in the status.components.job.savepointLocation of the CR. It won't be lost when the job crashes.