[ 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. 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. 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. 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 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)