[ https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534540#comment-17534540 ]
Gyula Fora edited comment on FLINK-27495 at 5/10/22 7:04 PM: ------------------------------------------------------------- [~thw] Seems like I forgot to mention that I am talking only about 1.15, with the current config (always setting the cluster shutdown off for app clusters) - Cancel with savepoint: the cluster (JM) remains there until explicitly deleted - Fatal Failure of the job: the cluster (JM) remains there until explicitly deleted - Job Finishes: Maybe you want to upgrade to a different source, replace batch with kafka source wouldbe a typical usecalse. Same applies as to the previous 2 was (Author: gyfora): Seems like I forgot to mention that I am talking only about 1.15, with the current config (always setting the cluster shutdown off for app clusters) - Cancel with savepoint: the cluster (JM) remains there until explicitly deleted - Fatal Failure of the job: the cluster (JM) remains there until explicitly deleted - Job Finishes: Maybe you want to upgrade to a different source, replace batch with kafka source wouldbe a typical usecalse. Same applies as to the previous 2 > Observer should update last savepoint information directly from cluster too > --------------------------------------------------------------------------- > > Key: FLINK-27495 > URL: https://issues.apache.org/jira/browse/FLINK-27495 > Project: Flink > Issue Type: New Feature > Components: Kubernetes Operator > Affects Versions: kubernetes-operator-1.0.0 > Reporter: Gyula Fora > Assignee: Gyula Fora > Priority: Blocker > Labels: pull-request-available > Fix For: kubernetes-operator-1.0.0 > > > The observer should fetch the list checkpoints from the observed job and > store the last savepoint into the status directly. > This is especially useful for terminal job states in Flink 1.15 as it allows > us to avoid cornercases such as the operator failing after calling > cancel-with-savepoint but before updating the status. -- This message was sent by Atlassian Jira (v8.20.7#820007)