Hi,

I have deployed a cluster with session mode on kubernetes and I can see one
deployment, services and one JM. I'm trying to run a SQL query through sql
client. for instance, 'INSERT INTO ... SELECT ...;'

When I run the query in cli, the Flink session is spinning up a TM for the
query and then the query is running in a job.

Now, I'm curious. How does Flink calculate the number of TMs for the query?
and also, Is it possible to run pre-spawned TMs for session mode? I'm
looking for a way to scale the computing resources. i.e., # of TM for the
jobs.

Thanks,
Youngwoo

Reply via email to