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