RestoreMode class not found

Hi, I have a flink job that can run on 1.20.0 but not 1.19.0. The error message is as below: Caused by: java.lang.ClassNotFoundException: org.apache.flink.core. execution.RestoreMode. So I compared the flink-core jar of both versions and it looks like the 1.19.0 one does not have this RestoreMod

Re: RestoreMode class not found

Hi Peng, I think this is an intentional change of Public API made in FLINK-34455[1]. In Flink 1.19.x series, `RestoreMode` is defined in `org.apache.flink.runtime.jobgraph`, which was moved to `org.apache.flink.core.execution` package after Flink 1.20. It’s suggested to declare dependencies th

Re: Flink K8 Operator: New Snapshot CRD Not Working

Thanks a lot for the confirmation Mate! Makes sense, in the meantime I fixed the issue by adding a ClusterRole & ClusterRoleBinding for the flink-operator ServiceAccount. Regards, Salva On Sun, Mar 9, 2025 at 2:11 PM Mate Czagany wrote: > Hi! > > When not using a cluster-wide installation, Ro

Re: Flink K8 Operator: New Snapshot CRD Not Working

Hi! When not using a cluster-wide installation, Role and RoleBinding resources to be able to interact with Flink resources are only installed in the namespaces listed in the `watchNamespaces` field. If the namespace where the operator is installed is not added to this list, RBAC will be configured