注册Master有两种,一种是registerWithMaster方法,一种是tryRegisterAllMasters方法,前者是单Master的情况,后者是多Master,一般情况下是满足HA机制,我们看一下registerWithMaster方法:
此时会调用tryRegisterAllMasters方法:
此时通过Akka通过消息机制发送消息给Master来注册程序,RegisterApplication是一个case class,来封装消息:
我们进入Master的源代码:
看一下接受客户端发送过来消息RegisterApplication的代码如下所示:
此时首先使用ApplicationInfo构建一些准备信息,然后会导致registerApplication代码的调用:
1、createAppliction:
2、registerApplication:
代码中就是一个注册应用的过程。
3、sender ! RegisteredApplication(app.id, masterUrl)方法是回复给发送者消息:
3.1、上面代码中的changeMaster(masterUrl):
3.2、进入listener.connected(appId)方法:
3.2.1、进入实现类SparkDeploySchedulerBackend的connected方法:
进入notifyContext()方法:
4、接着在Master的消息响应中会调用schedule方法:
可以看到schedule方法中首先要启动Driver程序,也就是有main函数的程序,然后在schedule中会调度Worker的过程:
上面代码分析
1、进入launchDriver(worker, driver)方法:
1.1、进入worker.actor ! LaunchDriver(driver.id, driver.desc)方法:
1.1.1、进入 driver.start()方法:
2、进入 launchExecutor(worker, exec)方法:
PS:代码分析的好乱呀,我这个笨猪
相关推荐
appclient - 全自动实名认证插件手机APP接口演示
资源分类:Python库 所属语言:Python 资源全名:sumologic-appclient-sdk-2.0.0.tar.gz 资源来源:官方 安装方法:https://lanzao.blog.csdn.net/article/details/101784059
python库。资源全名:sumologic_appclient_sdk-1.0.5-py3-none-any.whl
该项目是通过引导的。 您将在下面找到一些有关如何执行常见任务的信息。您可以在找到本指南的最新版本。 目录 更新到新版本 Create React App分为两个包: create-react-app是用于创建新项目的全局命令行实用程序。...
打包找不到 zkclient COULD NOT FIND zkclient-0.11 解压后将jar包与pom文件都放在.m2\repository指定路径下
用java实现的简单的浏览器,通过键入域名或ip地址可以打开要浏览的网页,前提是计算机必须联网。
可以给单个网页或整个网站加密,加密的种类可以是只对单个授权用户开放或对特定的多个授权用户开放。只有输入正确密码的用户才能访问加密后的文件且加密后的文件不依赖任何外部支持程序就可单独运行。
IBM Watson IoT Platform Javascript SDK安装npm install @...appClient . connect ( ) ;// Do stuffappClient . disconnect ( ) ;设备import { DeviceClient , DeviceConfig } from '@wiotp/sdk' ;let deviceConfi
电子科技大学 互联网程序设计,课件 内容丰富,深入浅出,很适合初学者
在appClient.py中初始化AppClient类2.运行主函数3.你会看到推荐结果笔记: 1.WordSegAPI文件夹用于分词2.usedict.txt 用作分词时的用户词典3.您发现的任何查询或错误,请告诉我,报告错误的高度奖励: 或发送电子...
GreeterCorba客户端corba 查找 ejb 用法: thufir@doge: $ thufir@doge: $ glassfish-4.1/glassfish/bin/appclient -client NetBeansProjects/GreeterCorbaClient/dist/GreeterCorbaClient.jar {org.omg.CORBA....
此源码包含AppClient与AppServer,是由安卓客户端与服务端交互源代码(包括安卓端和web端),即下载即使用,在eclipse中打开即可运行使用。
java接入支付宝现金红包以及登入授权,包含:支付宝加签下单,回调验签,登入加签,通过authCode获取userCode,退款,查询,打款,下载用户需要在appClient增加自己的appid,privatekey,alipublickey,pid,框架...