A.Supervisor進(jìn)程退出后能夠被Nimbus自動識別并拉起,不影響正在運行的業(yè)務(wù) B.Worker異常退出后能夠被Supervisor自動拉起,無需人工干預(yù) C.節(jié)點故障時,該節(jié)點上的任務(wù)會被重分配到其他正常的節(jié)點,無需人工干預(yù) D.Nimbus故障后,備Nimbus會自動接管,不影響正在運行的業(yè)務(wù)
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()