Flink运行时之客户端提交做业图-下

submitJob方法分析 JobClientActor经过向JobManager的Actor发送SubmitJob消息来提交Job,JobManager接收到消息对象以后,构建一个JobInfo对象以封装Job的基本信息,而后将这两个对象传递给submitJob方法:php case SubmitJob(jobGraph, listeningBehaviour) => val cli
相关文章
相关标签/搜索