Hi Alexis, Have you looked at flink-on-k8s-operator [1]? It seems to have the functionality you need: https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/0310df76d6e2128cd5d2bc51fae4e842d370c463/controllers/flinkcluster_reconciler.go#L569
I couldn't find many Flink-specific classes in the operator you mentioned, but in general classes annotated with Public and PublicEvolving are unlikely to change if that's your concern. Also pulling in Yang Wang. [1] https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/ Regards, Roman On Thu, Jul 1, 2021 at 7:49 PM Alexis Sarda-Espinosa <alexis.sarda-espin...@microfocus.com> wrote: > > Hello everyone, > > I'm testing a custom Kubernetes operator that should fulfill some specific > requirements I have for Flink. I know of this WIP project: > https://github.com/wangyang0918/flink-native-k8s-operator > > I can see that it uses some classes that aren't publicly documented, and I > believe it doesn't cover Flink K8s sessions, which I would like to use. > > Is there something I could use for Flink K8s sessions? And is it ok if I use > these classes knowing that I might need adjustments for future Flink versions? > > Regards, > Alexis. >
