If you want to use the RestClusterClient to do the job submission and
lifecycle management, the implementation in the
flink-kubernetes-operator[1] project may give you some insights.
You could also use /jars/:jarid/run[2] to run a Flink job. It is a pure
HTTP interface.
[1].
https://github.com/a
Hi,
We deploy a Flink session cluster on Kubernetes.
We want to submit jobs via java application using the REST API
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/rest_api/.
I'm trying to use the RestClusterClient which comes with the flink-clients
module but I couldn't find
