Flink支持多种安装模式

  • Local—本地单机模式，学习测试时使用

  • Standalone—独立集群模式，Flink自带集群，开发测试环境使用

  • StandaloneHA—独立集群高可用模式，Flink自带集群，开发测试环境使用

  • On Yarn—计算资源统一由Hadoop YARN管理，生产环境使用

1 Local本地模式

1.1 原理

  1. Flink程序由JobClient进行提交

  2. JobClient将作业提交给JobManager

  3. JobManager负责协调资源分配和作业执行。资源分配完成后，任务将提交给相应的TaskManager

  4. TaskManager启动一个线程以开始执行。TaskManager会向JobManager报告状态更改,如开始执行，正在进行或已完成。

  5. 作业执行完成后，结果将发送回客户端(JobClient)

1.2 操作