分布式运行模式如下图:

Flink 分布式运行模式

         JobManagersMaster): 主要的作用是管理tasks;安排checkpoint;失败以后重启 。 通常情况下只有一个JobManager,但是如果是需要其成为高可用的集群,可以配置多个JobManager,但是只有一个活跃的JobManager,其他的都是standby

        TaskManagersworker): 主要是用来在各个节点执行task,同时汇报信息给JobManager

相关文章:

  • 2022-12-23
  • 2022-01-01
  • 2021-12-20
  • 2022-01-01
  • 2022-01-01
  • 2021-07-11
  • 2021-05-17
  • 2021-05-10
猜你喜欢
  • 2022-01-15
  • 2021-06-18
  • 2021-12-23
  • 2019-01-06
  • 2021-08-19
  • 2018-04-10
  • 2022-01-01
相关资源
相似解决方案