There is no effect of the replicas setting in native mode. Native session
clusters are "elastic", the number of task managers are determined on the
fly based on the job requirements.
Gyula
On Thu, Aug 31, 2023 at 11:19 AM Krzysztof Chmielewski <
krzysiek.chmielew...@gmail.com> wrote:
> Thank you
Thank you for the response.
Yes currently in my PoC I'm using standalone integration.
Does ` spec.taskManager.replicas` has any effect when using native mode?
The reason I'm asking is that I need to know what is the "cacpacity" of
particular session cluster before I will submit the job into it.
A
I guess your question is in the context of the standalone integration
because native session deployments automatically add TMs on the fly as more
are necessary.
For standalone mode you should be able to configure
`spec.taskManager.replicas` and if I understand correctly that will not
shut down the
Just want to broth this up in case it was missed in the other
messages/queries :)
TL:DR
How to add TM to Flink Session cluster via Java K8s client if Session
Cluster has running jobs?
Thanks,
Krzysztof
pt., 25 sie 2023 o 23:48 Krzysztof Chmielewski <
krzysiek.chmielew...@gmail.com> napisał(a):
