streaming API java开发-1

streaming组件流程 Worker的启停：如果死掉了就死掉了 自动重试 不是自己 而是nimbus通过zookeeper接受worker的心跳得知 1.客户端提交任务jar包给nimbus 2.nimbus上交给zookeeper 3.supervisor 得知有任务之后从zookeeper下载 到nimbus上下载jar包 4.启动worker 向zookeeper注册 5.如果故障则通过

>>阅读原文<<