分布式运行模式如下图:
JobManagers(Master): 主要的作用是管理tasks;安排checkpoint;失败以后重启 。 通常情况下只有一个JobManager,但是如果是需要其成为高可用的集群,可以配置多个JobManager,但是只有一个活跃的JobManager,其他的都是standby
TaskManagers(worker): 主要是用来在各个节点执行task,同时汇报信息给JobManager
分布式运行模式如下图:
JobManagers(Master): 主要的作用是管理tasks;安排checkpoint;失败以后重启 。 通常情况下只有一个JobManager,但是如果是需要其成为高可用的集群,可以配置多个JobManager,但是只有一个活跃的JobManager,其他的都是standby
TaskManagers(worker): 主要是用来在各个节点执行task,同时汇报信息给JobManager