参考： https://stackoverflow.com/questions/43023961/spark-kryo-serializers-and-broadcastmapobject-iterablegowalladatalocation

问题描述：

在pairRDD 进行sortByKey时报错，找到130行，回去看需要sort的RDD ，发现里面涉及的broadcast

点进去 130行

原来的代码写法：

Map<String, Model> SPUMap = SPUProductFormateRdd.collectAsMap(); Broadcast<Map<String, Model>> bcSPUMap = sc.broadcast(SPUMap); //FIX 在本地执行的时候正常，在服务器上执行的时候就会报java.lang.UnsupportedOperationException

最后修改为：

Map SPUMap = new HashMap();
SPUMap.putAll(SPUProductFormateRdd.collectAsMap());
//                Map<String, Model> SPUMap = SPUProductFormateRdd.collectAsMap();
Broadcast<Map<String, Model>> bcSPUMap = sc.broadcast(SPUMap);

程序正常执行

至于为什么本地的时候可以，还没找到答案，也欢迎大神解答

参考：https://stackoverflow.com/questions/43023961/spark-kryo-serializers-and-broadcastmapobject-iterablegowalladatalocation问题描述：在pairRDD 进行sortByKey时报错，找到130行，回去看需要sort的RDD ，发现里面涉及的broadcast如下图：... String[] icarr = ic.split(","); List<String> iconlist = Arrays.asList(icarr); int len = iconlist.size(); for (int...