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
