Flink 的集群角色包括:

  1. JobManager:负责协调整个 Flink 应用程序的执行。它会接收客户端提交的应用程序,并将其转换为作业图。JobManager 还会监视整个作业的执行情况,处理故障,重新启动失败的任务等。

  2. TaskManager:负责执行具体的任务。每个 TaskManager 会启动一个或多个 TaskSlot,每个 TaskSlot 可以执行一个任务。TaskManager 还会接收由 JobManager 分配的任务,执行任务并将结果返回给 JobManager。

使用 Flink 集群时,需要根据需求启动相应的角色。一般来说,可以按照以下步骤使用 Flink 集群:

  1. 启动 Flink 集群:可以使用 Flink 自带的启动脚本启动集群,也可以使用其他工具如 Docker 等启动。

  2. 提交应用程序:使用 Flink 客户端提交应用程序到集群。客户端会将应用程序转换为作业图,并将其提交到 JobManager。

  3. 监视应用程序执行情况:可以使用 Flink 自带的 Web UI 监视应用程序的执行情况。也可以使用其他监控工具监视。

  4. 停止应用程序:使用 Flink 客户端停止应用程序的执行。

  5. 停止集群:使用 Flink 自带的停止脚本停止集群。


原文地址: https://www.cveoy.top/t/topic/oQD5 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录