Session mode on Kubernetes and # of TMs

Posted by Youngwoo Kim (김영우) on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Session-mode-on-Kubernetes-and-of-TMs-tp43625.html

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