savepoint流程
1. 执行savepoint
kubectl patch flinkdeployment/savepoint-job --type=merge -p '{"spec": {"job": 
{"state": "suspended", "upgradeMode": "savepoint"}}}’
2. 删除job
kubectl delete flinkdeployment/savepoint-job
3. 根据savepoint启动job
修改flinkdeployment yaml配置,添加如下
spec:
 ...
 job:
   initialSavepointPath: savepoint路径
执行kubectl apply -f xxx

> 2022年10月19日 下午3:53,Liting Liu (litiliu) <liti...@cisco.com.INVALID> 写道:
> 
> hi:
> 我在使用flink-operator 1.2.0 & flink 1.14.3,  使用flink-operator 成功手动生成了savepoint, 
> 但savepoint 生成之后, job 并没有自动取消。 希望savepoint 成功之后job 能自动取消。请问是哪里没操作对吗?还是一个已知问题?
> jobStatus:
>   jobId: 9de925e9d4a67e04ef6279925450907c
>   jobName: sql-te-lab-s334c9
>   savepointInfo:
>     lastPeriodicSavepointTimestamp: 0
>     lastSavepoint:
>       location: >-
>         
> hdfs://nameservice1/user/pda/savepoint/6077944532288/flink/sql-te/savepoint-9de925-b9ead1c58e7b
>       timeStamp: 1666163606426
>       triggerType: MANUAL
>     savepointHistory:
>       - location: >-
>           
> hdfs://nameservice1/user/pda/savepoint/6077944532288/flink/sql-te/savepoint-9de925-b9ead1c58e7b
>         timeStamp: 1666163606426
>         triggerType: MANUAL
>     triggerId: ''
>     triggerTimestamp: 0
>     triggerType: MANUAL
>   startTime: '1666161791058'
>   state: RUNNING
>   updateTime: '1666161828364'
> 

回复