一、在聚合前在map端先预聚合
使用reduceByKey/aggregateByKey代替groupByKey
二、一次处理一个分区的数据，不过要注意一个分区里的数据不要太大，不然会报oom
* 使用mapPartitions代替map
* 使用foreachPartitions代替foreach
三、使用重分区
* 在过滤后使用算子coalesce()，避免过滤后可能产生的数据倾斜
原文：https://www.cnblogs.com/feizaijiawenzhu/p/14603611.html