模式类型

Flink 任务提交模式共有三种：

  • Application Mode,
  • Session Mode,
  • Per-Job Mode。

Flink 任务提交模式 - 图1)

Application Mode

在其它模式中，应用的 main()方法执行是在客户端一侧，它需要做：

  1. 本地下载应用依赖。
  2. 执行 main()方法生成任务的 JobGraph。
  3. 将 JobGraph和依赖上传到集群。

这种模式会导致客户端压力非常大，占用网络带宽以将 Flink 和 应用所需要的 JAR 包上传到集群中，消耗 CPU 资源解析应用的 main()方法生成 JobGraph。
而 Application Mode 任务提交模式会为每个提交的任务创建对应的 JobManager，而 main()方法的解析是由这个 JobManager所完成的。Application Mode是以用户的 jars 已经存在公共路径下，对于 JobManager或 TaskManager来说，都可以获取到。
Application Mode

  1. source 
  2. kinit