ardhani
ardhani

Reputation: 333

How do Flink job managers get assigned when deployed in application mode?

From https://flink.apache.org/news/2020/07/14/application-mode.html

Creating a cluster per application can be seen as creating a session cluster shared only among the jobs of a particular application and torn down when the application finishes.

Does each job has separate JM or shared? Image is showing something different, want to clarify on this. enter image description here

Upvotes: 1

Views: 479

Answers (2)

Akhil
Akhil

Reputation: 85

In application mode assumption is, an application is made up of multiple jobs. Each job will be isolated has separate Job Manager and Task manager (thus providing the same resource isolation and load balancing guarantees as the Per-Job Mode). Another different in application mode is main() method (pre-flight) is executed on Job manager instead of client.

Upvotes: 0

Till Rohrmann
Till Rohrmann

Reputation: 13346

A Flink application can consist of multiple jobs/parts. When using the application mode, Flink deploys a dedicated cluster for an application. This cluster contains a JobManager process which will be used to run all jobs/parts of the Flink application. Hence, the process will be shared by the different parts of the application.

Upvotes: 1

Related Questions