[
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
by advancing the watermark to the end, 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 taking a savepoint.
was:
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. This can be
achieved by advancing the watermark to the end of time.
If the job fails to drain and hits timeout or any other error, it can be
cancelled without drain.
> 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 by advancing the watermark to the end, 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 taking a savepoint.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
