Spark-源码学习-集群启动-standalone-worker-心跳机制
一、概述
Worker 通过发送心跳实现的汇报运行状态
二、源码
当 worker 向 Master 注册成功后会接收到 Master 回复的 RegisteredWorker
消息,Worker 使用 handleRegisterResponse 方法处理 RegisteredWorker
消息时,将会向 forworaMessageScheduler 提交以 HEARTBEAT_MILLIS
作为间隔向 Worker 自身发送 SendHeartbeat
消息的定时任务。Worker 的 receive 方法实现了对 SendHeartbeat
消息的处理
如果 connected 为 true,则调用 $sendToMaster$ 方法,向 Master 发送 Heartbeat 消息(此消息将携带Worker 的 ID 和 Worker 的 RpcEndpointRef)
三、总结
本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 Joker!
评论
ValineTwikoo