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对象