MapPartition一次oom問題解決

一、問題：每次跑到MapParititon就會停住 看起來是repartition的問題，實際出問題的是以前的mapPartition executor表現： 出問題的代碼：web val process_data = data.mapPartitions( rs => { val delLabelMapbc = delLabelMap.value

>>阅读原文<<