[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manan Mangal updated FLINK-32700:
---------------------------------
Description:
During cancel job with savepoint upgrade mode, jobs should be allowed to drain
before they are stopped, so that the in-flight data is not lost.
If the job fails to drain and hits timeout or any other error, it can be
cancelled without drain.
was:
During cancelJob, all job types are cancelled with stateless upgrade mode
workflow regardless of their actual upgrade mode.
In case of savepoint upgrade mode, the job should be create a savepoint and
drain it before stopping the job. We can use the flink endpoint
stopWithSavepoint which allows this functionality.
> Support job drain for Savepoint upgrade mode jobs in Flink Operator
> -------------------------------------------------------------------
>
> Key: FLINK-32700
> URL: https://issues.apache.org/jira/browse/FLINK-32700
> Project: Flink
> Issue Type: Improvement
> Components: Kubernetes Operator
> Affects Versions: kubernetes-operator-1.5.0
> Reporter: Manan Mangal
> Priority: Major
>
> During cancel job with savepoint upgrade mode, jobs should be allowed to
> drain before they are stopped, so that the in-flight data is not lost.
> If the job fails to drain and hits timeout or any other error, it can be
> cancelled without drain.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
