开发者社区> 问答> 正文

在集群启动过程中JobManger起到些什么作用?

在集群启动过程中JobManger起到些什么作用?

展开
收起
游客4iodw4vsbx244 2021-12-08 18:51:56 532 0
1 条回答
写回答
取消 提交回答
  • JobManager的职责主要是接收Flink作业,调度Task,收集作业状态和管理TaskManager。它包含一个Actor,并且做如下操作:

    RegisterTaskManager: 它由想要注册到JobManager的TaskManager发送。注册成功会通过AcknowledgeRegistration消息进行Ack。

    SubmitJob: 由提交作业到系统的Client发送。提交的信息是JobGraph形式的作业描述信息。

    CancelJob: 请求取消指定id的作业。成功会返回CancellationSuccess,否则返回CancellationFailure。

    UpdateTaskExecutionState: 由TaskManager发送,用来更新执行节点(ExecutionVertex)的状态。成功则返回true,否则返回false。

    RequestNextInputSplit: TaskManager上的Task请求下一个输入split,成功则返回NextInputSplit,否则返回null。

    JobStatusChanged: 它意味着作业的状态(RUNNING, CANCELING, FINISHED,等)发生变化。这个消息由ExecutionGraph发送。

    2021-12-08 18:55:45
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
运用新技术解决有状态应用的冷热迁移挑战 迁移策略+新容器运行时 立即下载
Flink中的两类新型状态存储 立即下载
Android内存泄漏自动化链路分析组件--Probe 立即下载