Hi Krzysztof, You may want to check flink-kubernetes-operator-api ( https://mvnrepository.com/artifact/org.apache.flink/flink-kubernetes-operator-api), here's an example for reading FlinkDeployments https://github.com/sap1ens/heimdall/blob/main/src/main/java/com/sap1ens/heimdall/kubernetes/FlinkDeploymentClient.java
And you can use standard kubernetes client methods for creating resources, e.g. "createOrReplace". On Wed, Aug 16, 2023 at 5:33 AM Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> wrote: > Hi, > I have a use case where I would like to run Flink jobs using Apache Flink > k8s operator. > Where actions like job submission (new and from save point), Job cancel > with save point, cluster creations will be triggered from Java based micro > service. > > Is there any recommended/Dedicated Java API for Flink k8s operator? > I see that there is standard k8s java client [1] and I'm wondering if this > would be sufficient for Flink jobs. > > [1] https://github.com/kubernetes-client/java >
