worker流式上报时序图
2022-05-18 11:40:10 5 举报
master和worker通信
作者其他创作
大纲/内容
worker
worker接收ACK,如果master响应超时,抛出异常
worker上报完成
worker接接收ACK
等待master的complete,超过给定complete时间抛出异常
确认所有批次上报请求都收到ACK,如果在响应时间内批次不对抛出异常
master启动
调用registerWithMaster,向master上报
master
关闭stream
调用RegisterStreamer类的方法registerWithMaster
worker启动
master向worker返回ACK
worker向master发送下一批次上报请求
worker向master发送第一批次上报请求
启用流式上报
构建RegisterStreamer对象
收藏
0 条评论
下一页