Flink operator job restart
Hi Flink users, When using Flink operator, how to restart jobs from a checkpoint. I am used to the Flink Kubernetes native deployment, where I can run flink run -s How to achieve that in Flink operator Thanks Ivan
Re: Flink operator job restart
Hi, lvan You can refer to the five-part that restore the job in [1]. [1] https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.6/docs/operations/upgrade/#2-upgrading-with-existing-flinkdeployments Best, Ron Ethan T Yang 于2023年8月10日周四 12:28写道： > Hi Flink users, > > When using Flink operator, how to restart jobs from a checkpoint. I am > used to the Flink Kubernetes native deployment, where I can run > > flink run -s > > How to achieve that in Flink operator > > Thanks > Ivan
Re: Flink operator job restart
Hi Ethan: You can restart jobs with a specified checkpoint directory as [1]. But generally, we often restart jobs with savepoint, you can refer to [2] for more information. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/checkpoints/#resuming-from-a-retained-checkpoint [2] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/savepoints/ Best, Shammon FY On Thu, Aug 10, 2023 at 2:43 PM liu ron wrote: > Hi, lvan > > You can refer to the five-part that restore the job in [1]. > > [1] > https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.6/docs/operations/upgrade/#2-upgrading-with-existing-flinkdeployments > > Best, > Ron > > Ethan T Yang 于2023年8月10日周四 12:28写道： > >> Hi Flink users, >> >> When using Flink operator, how to restart jobs from a checkpoint. I am >> used to the Flink Kubernetes native deployment, where I can run >> >> flink run -s >> >> How to achieve that in Flink operator >> >> Thanks >> Ivan > >
回复: Flink operator job restart
Hi Ethan, You can refer to the K8s operator doc on how to do a stateful job upgrade: Job Management | Apache Flink Kubernetes Operator<https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.6/docs/custom-resource/job-management/#stateful-and-stateless-application-upgrades>. Best, Zhanghao Chen 发件人: Ethan T Yang 发送时间: 2023年8月10日 12:27 收件人: user@flink.apache.org 主题: Flink operator job restart Hi Flink users, When using Flink operator, how to restart jobs from a checkpoint. I am used to the Flink Kubernetes native deployment, where I can run flink run -s How to achieve that in Flink operator Thanks Ivan
