transfer a running job to flinkk8soperator

[nealsun]

Is it possible to tranfer a running flink job to flinkk8soperator seamlessly, especially recover from a savepoint?

[glaksh100]

Hi @nealsun,

Thanks for the question. In order to migrate a Flink job to run on flinkk8soperator, you can update the SavepointInfo section of the CRD with a SavepointLocation.

Code: https://github.com/lyft/flinkk8soperator/blob/ba1533b757c2ef5c541443df6d08ed5be069f163/pkg/apis/app/v1beta1/types.go#L125

Example:

spec:
  savepointInfo:
     savepointLocation: <INSERT SAVEPOINT PATH HERE>

[nealsun]

ok, I will have a try.