A.Supervisor進程退出后能夠被Nimbus自動識別并拉起,不影響正在運行的業(yè)務 B.Worker異常退出后能夠被Supervisor自動拉起,無需人工干預 C.節(jié)點故障時,該節(jié)點上的任務會被重分配到其他正常的節(jié)點,無需人工干預 D.Nimbus故障后,備Nimbus會自動接管,不影響正在運行的業(yè)務
A.lines.flatMap(_.split”””)).map(word=>(word,1)).reduce(_+_).print() B.lines.flatMap(_.split”””)).map(word=>(word,word.length())).reduceByKey(_+_).print() C.lines.flatMap(_.split”””)).map(word=>(word,1)).reduceByKey(_+_).print() D.lines.flatMap(_.split”””)).flatMap(word=>(word,1)).groupByKey(_+_).print()