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' >