Hi Vladislav!

I am afraid there is no way to specify resources independently for jobs
within a session cluster currently in Flink.

For this I suggest using the Application Mode instead where each job can
have its own resources.

In any case you should check out the Flink Kubernetes Operator -
https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/
It allows you to manage session clusters, session jobs and application
deployments very conveniently :)

Cheers,
Gyula

On Tue, Aug 2, 2022 at 11:17 AM Vladislav Keda <
vladislav.k...@glowbyteconsulting.com> wrote:

> Hi,
>
> I'm trying to specify different TaskManager resources for different Flink
> jobs on Kubernetes Session Cluster. Can you help me to find a way to do
> that?
>
> I use this options, but Flink picks them up only when I start new
> Kubernetes Session deployment:
> Memory:
> jobmanager.memory.process.size
> <https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/#jobmanager-memory-process-size>
> , taskmanager.memory.process.size
> <https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/#taskmanager-memory-process-size>
> CPU:
> kubernetes.jobmanager.cpu
> <https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/#kubernetes-jobmanager-cpu>
> , kubernetes.taskmanager.cpu
> <https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/#kubernetes-taskmanager-cpu>
>
> *FYI*
> I deploy Flink jobs on cluster and set up specific configuration
> parameters for jobs using
> *org.apache.flink.client.program.rest.RestClusterClient<?>*
>
> Flink version - 1.13.6.
>
> ---
>
> Best Regards,
> Vladislav Keda
>

Reply via email to