JobManager和TaskManager交互通过Task对象
Actor System是Akka最重要的一个组件。
Job Dispatcher负责接收Client提交的JobGraph对象，然后拆分成不同的作业，提交到TaskManager. 这个过程会涉及到Job的分发。
standlone模式和yarn模式的ResourceManager是不同的实现。
TaskManager启动后会主动向JobManager进行一个rpc远程的Connection注册，
TaskManager是一个JVM进程，那么对于Task Slot资源池，是一个Thread Pool
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）