Flink入门系列--安装部署及任务提交(1.14.3版本)

时间:2024-10-11 07:07:02

部署模式

Flink 的部署模式分为3种:

  • Application 模式
  • Per-Job 模式
  • Session 模式
    在这里插入图片描述

Application 模式

Application 模式即 Flink 为1个应用专门创建1个集群,Flink集群和应用同生命周期,Application 的main()方法将由 JobManager执行。在其他部署模式下,用户 Jar 文件是通过 RPC 来进行分发的,因为需要走网络IO,当用户 Jar 文件较大时,JobManager 加载用户 Jar 文件将是1个耗时的操作。为了避免上述问题,Application 模式要求用户将 Jar 文件放置到 Flink 的 classpath 下,一般是 Flink 根目录下的 lib 目录。

Application 模式允许提交由多个 Job 组成的 Application。在main()方法中,如果是使用阻塞的 execute() 来提交的任务,不同任务将依次执行,即同一时刻仅能有1个任务在执行;如果想同时执行多个任务,则需要使