streaming API java開發-1

streaming組件流程 Worker的啓停：如果死掉了就死掉了 自動重試 不是自己 而是nimbus通過zookeeper接受worker的心跳得知 1.客戶端提交任務jar包給nimbus 2.nimbus上交給zookeeper 3.supervisor 得知有任務之後從zookeeper下載 到nimbus上下載jar包 4.啓動worker 向zookeeper註冊 5.如果故障則通過

>>阅读原文<<