Deploy a Flink session cluster natively on K8s with multi AZ

2022-03-27 Thread Almog Rozencwajg
Hi, >From the documentation, deploy a Flink session cluster natively on K8S is by >running a shell script.

Submit job to a session cluster on Kubernetes via REST API

2022-03-05 Thread Almog Rozencwajg
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

Job Manager High Availability using Kubernetes HA Services is not working with custom S3 encrypted client

2022-02-20 Thread Almog Rozencwajg
Hi, We are using Flink version 1.12.2 running on Kubernetes using native Kubernetes integration. We are trying to use the job manager HA describes in the Flink official documentation Kubernetes HA