[FLINK-29695] Create a utility to report the status of the last savepoint

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: kubernetes-operator-1.3.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• Assignee: Clara Xiong
• Reporter: Clara Xiong
• Created: 19/Oct/22 16:33
• Updated: 21/Nov/22 17:37
• Resolved: 21/Oct/22 08:57

Description

Users want to know the status of last savepoint, especially for manually triggered ones, to manage savepoints.

Currently, users can infer the status of the last savepoint (PENDING, SUCCEEDED and ABANDONED) from jobStatus.triggerId, lastSavepoint.triggerNonce, spec.job.savepointTriggerNonce and savepointTriggerNonce from last reconciliation. If the last savepoint is not manually triggered, there is no ABANDONED status, only PENDING or SUCCEEDED.

Creating a utility will encapsulate the internal logic of Flink operator guard against regression by any future version changes.

 

Issue Links

• relates to: FLINK-30047 getLastSavepointStatus should return null when there is never savepoint completed or pending
• relates to: FLINK-30119 Breaking change: Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint field whether it is completed or pending
• links to: GitHub Pull Request #406