Flink提交命令区别

不懂在学习

你好，楼主 这是两种在 YARN 上提交 Flink 任务的方式：

flink run -t yarn-per-job 方式会在 YARN 上启动一个新的 Application Master，并在该 Application Master 上提交 Flink 任务。这种方式的优点是可以避免多个 Flink 任务之间的干扰，每个任务都有一个独立的 Application Master。但是，这种方式的缺点是每次提交任务都需要启动一个新的 Application Master，如果任务数量较多，会占用大量的 YARN 资源。

flink run -m yarn-cluster 方式会在 YARN 上启动一个 Flink 集群，并将 Flink 任务提交到该集群中。这种方式的优点是可以利用 YARN 资源，有效地管理任务资源，并且多个 Flink 任务可以共享一个集群，降低了资源占用。但是，这种方式的缺点是不同任务之间可能会有资源争用的问题，需要根据实际情况进行调整。

选择哪种方式取决于具体情况。如果任务量较大，每个任务都需要一定的资源，可以考虑使用 flink run -t yarn-per-job 方式。如果任务量较小，可以考虑使用 flink run -m yarn-cluster 方式，以节省资源。如果任务之间存在资源争用的问题，可以通过调整资源配置和任务调度策略来解决。

望采纳！

Per-Job 新老版本启动方法 - 老版本（<=1.10）

flink run -m yarn-cluster -c xxx xxx.jar

• 新版本（>=1.11）

flink run -t yarn-per-job -c xxx xxx.jar

Per-Job 启动的三个进程 - CliFrontend - YarnJobClusterEntryPoint：AM执行的入口类 - YarnTaskExecutorRunner：Yarn模式下的TaskManager的入口类